rx-scala

1熱度

1回答

我遇到了使用RxJava背壓的問題。基本上，我有一個生產者生產的產品比消費者可以處理的要多，並且希望有一些緩衝隊列來處理我可以處理的物品，並請求完成其中的一些物品，如本例中： object Tester extends App { Observable[Int] { subscriber => (1 to 100).foreach { e => subscriber.onN

0熱度

1回答

無法打印分組

後可觀察的項目可以不明白爲什麼預期以下rxscala代碼是不工作： import rx.lang.scala.Observable object MyTest extends App { case class ProjectEvent(projectName: String, description: String) val projectEvents: Observa

0熱度

1回答

通過觀察到自身

我想通過自己觀察到的片流，例如： val source = Observable.from(1 to 10).share val boundaries = source.filter(_ % 3 == 0) val result = source.tumblingBuffer(boundaries) result.subscribe((buf) => println(buf.toStrin

2熱度

1回答

如何實現單次使用訂購的ReplaySubject？

怎樣纔可以有一個單用戶ReplaySubject認爲：緩衝區與onNext()收到的所有事件，直到有人訂閱它，一旦有人訂閱它，所有緩存事件轉發到用戶，擦除他們從ReplaySubject緩衝液（出於性能原因）和隨後的事件僅轉發到用戶（沒有更多的緩衝），如果多於一個觀察者預訂它，則拋出異常，所有緩衝的EV根據每個事件生成的時間排序，並在訂閱期間按訂單的順序將訂單轉發給訂戶？此外，這是否有意

0熱度

1回答

RxJava/Scala Observable垃圾如何使用數據？

我在Rx很新鮮，我似乎有可觀察的緩衝區事件數據。使用cold observable或replay，即使很長時間後，數據流也會發送給後面的觀察者。但是什麼時候它會被垃圾？此外，使用Rx時應該關心內存？

0熱度

1回答

爲什麼不執行爲RxScala的doOnSubscribe函數提供的函數？

val x: Observable[Int] = Observable.just(1).doOnSubscribe(() => println(s"subscribed")) val y = x.subscribe(t => println(s"got item: $t")) println("all done") 我還以爲這個代碼將打印 subscribed got i

2熱度

2回答

如何產生一個從另一個

可觀察比方說，我們有源可觀察到一個int： val source:Observable[Int] 我想創造另一個觀察的，生產值，它們的區別在源來首次出現值大於10 ： def detect() = Observable[Int]( subscriber => if (!subscriber.isUnsubscribed) { var start:Option[In

2熱度

1回答

可運行的行爲主題？

是否有可能有一種BehaviorSubject暫停和恢復開關？像PausableBehaviorSubject.pause()和PausableBehaviorSubject.resume()？這怎麼可能完成？這個想法是，暫停時，主題不會轉發通過PausableBehaviorSubject.onNext()收到的事件，而是隻存儲最後一個。在恢復時（或者在訂購時，如果不暫停），PausableB

1熱度

1回答

調用（超載）RxJava從斯卡拉

功能，我想從Observable就像這樣的數組創建一個Observable： package rxtest import concurrent._ import concurrent.ExecutionContext.Implicits.global import rx.lang.scala._ import rx.lang.scala.JavaConversions._ impor

0熱度

1回答

爲什麼`collect`讓觀察者沒有收到通知？

我使用rxscala，發現了一個非常微妙的問題，我的代碼是簡單求於以下內容： import rx.lang.scala.Observable import rx.lang.scala.subjects.PublishSubject object SubtleBug extends App { case class Projects(projects: List[Project]