rx-netty

    0熱度

    1回答

    Rx-Netty：將websocket框架拆分爲多個片段

    我已經使用Rx-Netty來實現websocket服務器。 io.netty.handler.codec.CorruptedFrameException: Max frame length of 65536 has been exceeded. 所以我想實現在服務器上的WebSocket響應碎片：當Java web套接字客戶端調用服務器端API返回的大型數據集，我看到在客戶端下面的錯誤即將結果集分
    rx-java rx-netty 2015-10-12

    0熱度

    1回答

    爲什麼RxNetty使用線程池？

    最近我看到了io.reactivex.netty.client.PoolExhaustedException。不是netty應該使用O（1）個線程運行？是不是廣告作爲異步，非阻塞，使用事件循環客戶端？ 如果它使用線程池，那麼爲什麼我需要它？我可以在3行代碼中創建自己的池，並使用它來阻止連接。
    java netty nio rx-netty 2016-11-16

    0熱度

    1回答

    Rx Netty：異步客戶端不斷收到「內容流已處理」錯誤

    在下面的代碼中，我試圖使用Rx Netty構建一個簡單的異步HTTP客戶端，它向api發出75個POST請求。我遇到的問題是，我不斷收到「java.lang.IllegalStateException：內容流已被丟棄。」錯誤。 我在做什麼錯在這裏？這是否與此：https://github.com/ReactiveX/RxNetty/issues/264 NioEventLoopGroup prov
    rx-java rx-netty 2017-06-05

    0熱度

    1回答

    爲什麼netty客戶端返回Observable <Observable <ByteBuf>>而不是Observable <ByteBuf>？

    教程/實施例表明： Observable<HttpClientResponse<ByteBuf>> httpGet = RxNetty.createHttpGet("http://xxxx"); Observable<Observable<ByteBuf>> byteBuffers = httpGet.map(HttpClientRespo
    java netty reactive-programming rx-netty 2016-11-27

    0熱度

    1回答

    Spring中的異步消息傳遞網關與RxNetty的集成

    我試圖將Spring集成中的異步消息傳遞網關與RxNetty（異步HTTP）結合起來。基本上我想要的是向調用線程返回observable/CompletableFuture，並在調用線程中使用Observable的zip/map/flatmap來創建一批出站HTTP調用。我只是想看看這是否可能。此外，如果不是使用Rxjava構造，我最好使用聚合器eip來構建簡單的工作流程。
    spring-integration rx-netty 2017-06-20

    0熱度

    1回答

    我如何使用TestScheduler和RxNetty http服務器

    我正在嘗試創建一個模擬服務器，以幫助更輕鬆地爲在事件流上運行的客戶端編寫測試。 我正在用RxNetty實現服務器和客戶端，我的問題是如何使用RxNetty的TestScheduler來控制何時發生事件。 這是我（簡化）服務器： final Observable<Event> events = Observable.just(...); final TestScheduler testSc
    java rx-java rx-netty 2015-12-22
最新問題