reactive-streams

1熱度

1回答

使用Reactive Streams Processor作爲事件總線通常可以嗎？

我開始學習反應流，因爲我對使用RxJava替代更傳統的事件總線的新趨勢感到好奇。 This blog post是如何完成的典型描述。如果我理解正確，RxJava 1.x並不嚴格執行反應流，但它非常相似。版本2.0包含一些符合要求的類，或者至少通過TCK，因此此代碼的更新版本可能會有所不同。 public class UserLocationModel { private Publish

0熱度

1回答

Spring WebFlux：block（）方法在Spring Data Reactive MongoDB中返回null

我在嘗試學習項目Reactor並且遇到問題。 @Test @DisplayName("check that standaloneUser fields are correct") void validateUserFields() { userService.save(standaloneUser).subscribe(); assertEquals(userService

0熱度

3回答

春WebFlux：無MongoDB的

我是新來春堆，所以我想重構這個簡單的彈簧數據（在科特林）方法： fun save(user: User): Mono<User> { if (findByEmail(user.email).block() != null) { throw UserAlreadyExistsException() } user.password = passwordEnc

5熱度

1回答

異步，在Java矢量/流數據可組合的返回值9

說我有一個API，基於一些查詢條件，會發現或構建一個小窗口： Widget getMatchingWidget(WidgetCriteria c) throws Throwable 的（同步）的客戶端代碼的外觀像： try { Widget w = getMatchingWidget(criteria); processWidget(w); } catch (Throwa

8熱度

2回答

反應流 - 批處理超時

我正在尋找替換一個自制的日誌處理庫，看起來非常接近ReactiveStreams與io.projectreactor。我們的目標是減少我們維護的代碼，並利用社區添加的任何新功能（關注操作員融合）。作爲開始，我需要使用stdio並將多行日誌條目合併到流水線下方的文本blob中。該用例在Filebeat文檔的multiline log entries一章中詳細解釋（除了我們希望它在進程中）。到

1熱度

2回答

流過濾，直到另一個流發射，但一旦第二流發射，重新發送這些過濾的發射

我有一個Foo流。 Foo發出要求佈置的Android視圖（寬度和高度> 0）。我用RxBinding爲該即 fooOservable() .subscribe(foo -> {}); RxView.preDraws(mPager,() -> true) .take(1); 當這種可觀察到的發射（或完成辯論，因爲的取）視圖佈局。我需要的是讓fooObserva

0熱度

1回答

反應流Kafka流扇出到http演員

我是非常新的Akka Streaming和反應流。我有一個問題：是否有可能讓一個剩餘API接收一條消息，將其放在Kafka Bus上，然後Kafka流消費者將消息聚合到最大值。時間窗口並重新回到答案？如何實現這樣一個系統？或從哪裏開始？感謝

1熱度

1回答

將無限流的無限流轉換爲無限流 - 活性X

0熱度

1回答

如何一些記錄從表A複製到表B具有光滑的流媒體和阿卡串流

有兩個表TableA和TableB。我需要一些記錄複製從TableA到TableB。我用slick-3.0，並使用以下方法： import akka.stream._ import akka.stream.scaladsl._ ... //{{ READ DATA FROM TABLE A val q = TableA.filter(somePredicate).result val

1熱度

2回答

Flux的組合結果來自Mono

我開始使用Project反應堆，並且我很少掙扎的一個地方是我如何將來自Mono的物體與Flux結合在一起。這是我的使用情況： public interface GroupRepository { Mono<GroupModel> getGroup(Long groupId); } public interface UserRepository { Flux<User>