取消訂閱後我的訂閱保持運行

我正在嘗試學習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()

我認爲這意味着我的訂閱仍在運行，但收到空的緩衝區後，如何停止訂閱？

來源

2013-12-08 Filipe Pais Lenfers

也許coursera論壇可能是這個問題的一個更好的地方嗎？ –

@MarkLister我按照你的建議在coursera論壇（https://class.coursera.org/reactive-001/forum/thread?thread_id=1858）上提出這個問題並得到了答案。這似乎是一個錯誤：https://github.com/Netflix/RxJava/issues/559。韓國社交協會。 –

我在coursera論壇（class.coursera.org/reactive-001/forum/thread?thread_id=1858）上詢問了這個問題，作爲@MarkLister建議並得到了答案。

這似乎是在0.15.1版中的錯誤：github.com/Netflix/RxJava/issues/559

來源

2013-12-09 18:22:57

取消訂閱後我的訂閱保持運行

回答

相關問題