rx-scala

0熱度

1回答

我有我需要解析字符串的應用程序，我使用它RxScala。我的代碼： import java.util.concurrent.TimeUnit import rx.lang.scala.Subject import rx.lang.scala.schedulers.NewThreadScheduler import rx.lang.scala.subjects.{SerializedSubje

1熱度

1回答

如何在使用filterEvents（）時移除事件過濾器？

你好，我想，所以我這樣做是爲了重新包裝的鼠標事件使用rxscala和scalafx在一起： def mouseEvents: Observable[MouseEvent] = Observable.create(observer => { stage.filterEvent(MouseEvent.Any)((event: MouseEvent) => { observer.on

2熱度

1回答

RxScala可觀察到從未運行

用下面build.sbt： name := "blah" version := "1.0" scalaVersion := "2.11.6" libraryDependencies ++= Seq("io.reactivex" % "rxscala_2.11" % "0.24.1", "org.scalaj" %% "scalaj-http" % "1.1.4") 和驗證碼： im

3熱度

2回答

追蹤[rx]大圖中的可觀察異常到源代碼

當您有一個大的可觀察圖形（即使用merge,groupBy,join等組成的可觀察組合多次），並拋出異常時，有時很難計算排除異常源自的地方。我想知道是否有可能找出源文件中的可見操作符被喚醒的地方。一個例子應該更清楚。例如，給出以下IllegalStateException: Only one subscriber allowed!和堆棧跟蹤，我想知道是否有可能找出行數operatorMerge，

2熱度

2回答

可觀察的異常處理

我正在學習RxScala並來到這個非常合成的片段。我試圖處理例外的onError塊： def doLongOperation():String = { (1 to 10).foreach { _ => Thread.sleep(100) print(".") } println() if (System.currentTim

0熱度

1回答

斯卡拉未來衍生觀察到的回調沒有得到所謂的

使用Scala的2.11.7，rxscala_2.11 0.25.0，rxjava 1.0.16，我oddFutures回調則不會調用在AsyncDisjointedChunkMultiprocessing.process()： package jj.async import scala.concurrent.Future import scala.concurrent.ExecutionC

0熱度

1回答

Scala Observable創建區塊我的期貨

我想處理ea。異步查詢提取（可能會對每個查詢進行多次提取）。爲了做到這一點，我將處理函數（返回Future）傳遞給我的查詢方法來調用它。取。我不知道我的查詢的結果大小;我只知道我的抓取的最大尺寸。因此，我的查詢返回Observable（而不是List，例如，我需要事先知道尺寸）。唯一的問題是，當我使用Observablecreate或apply時，它會在內部阻塞，直到我的Future完成，然後它調

0熱度

2回答

實現循環作業重複不超過每秒

假設我們再次有這樣的事情： while (true) { val job = Future { doSomething(); 1 } val timeout = Future { Thread.sleep(1000); 2 } val both = for (j <- job; t <- timeout) { println("Done") }