1

RxScala を学習しようとしています。サブスクリプションを使用Observable.interval(1 second).buffer(10 seconds)して値を出力していますが、サブスクリプションを正しく解除できません。サブスクリプションのサブスクリプションを解除した後も、サブスクリプションは実行され続けますが、結果は空になります。

私のコード:

import scala.language.postfixOps
import scala.concurrent.duration.DurationLong
import scala.concurrent.duration.DurationInt
import scala.concurrent.duration.Duration
import rx.lang.scala._

val o = Observable.interval(1 second).buffer(10 seconds)
val s = o.subscribe(
          { n =>  println("buffer --> " + n) }, 
          e => { e.printStackTrace() },
          () => { println("Completed!") })

結果をうまく出力します：

buffer --> Buffer(0, 1, 2, 3, 4, 5, 6, 7, 8)
buffer --> Buffer(9, 10, 11, 12, 13, 14, 15, 16, 17, 18)
buffer --> Buffer(19, 20, 21, 22, 23, 24, 25, 26, 27, 28)
buffer --> Buffer(29, 30, 31, 32, 33, 34, 35, 36, 37, 38)

しばらくして、購読を解除します。

s.unsubscribe

そして、私はまだプリントを取得しますが、空のバッファを使用します:

buffer --> Buffer()

これは、サブスクリプションがまだ実行されていることを意味すると思いますが、空のバッファーを受信して​​います。サブスクリプションを停止するにはどうすればよいですか?

4

1 に答える 1

1

@MarkLister が提案して回答を得たので、coursera フォーラム (class.coursera.org/reactive-001/forum/thread?thread_id=1858) でこの質問をしました。

バージョン 0.15.1 のバグのようです: github.com/Netflix/RxJava/issues/559

于 2013-12-09T18:22:57.543 に答える