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]