1

rxscala を使用すると、次のようにオブザーバブルをサブスクライブできます。

val stream = Observable.just(1, 2, 3)

stream.subscribe(x => doSomething(x))
stream.subscribe(x => doSomething(x))
stream.subscribe(x => doSomething(x))
stream.subscribe(x => doSomething(x))

側からすべてのオブザーバー (4 つあります) のサブスクライブを解除することは可能streamですか?

4

0 に答える 0