reactor

    5熱度

    3回答

    我想設置超時我的WebClient超時,這裏是當前的代碼: SslContext sslContext = SslContextBuilder.forClient().trustManager(InsecureTrustManagerFactory.INSTANCE).build(); ClientHttpConnector httpConnector = new ReactorClientH

    1熱度

    1回答

    我使用SpringBoot 2和Spring 5(RC1)來公開反應式REST服務。但我無法爲這些控制器編寫單元測試。 這裏是我的控制器 @Api @RestController @RequestMapping("/") public class MyController { @Autowired private MyService myService;

    0熱度

    1回答

    我有一系列的客戶端需要通過ws協議不斷連接到我的服務器。由於許多不同的原因,連接偶爾會下降。這是可以接受的,但是當它發生時,我希望我的客戶重新連接。 目前我的臨時解決方法是讓父進程啓動客戶端,當它檢測到連接丟失時,終止它(客戶端從不處理任何關鍵數據,不會對sigkill產生副作用),並重新創建一個新客戶端。雖然這樣做的工作,我非常希望解決實際問題。 這大致是我的客戶: from autobahn.

    0熱度

    1回答

    調用函數我有twisted.internet.reactor問題,我所有的客戶有完全一致的環境中,但只有一些經驗,這個問題: 他們正確地通過ws和交流第一幾條消息connectTCP到服務器。在約一分鐘,他們應該通過 def execute(self, message, callback=None): print(">>>", message, flush=True) reac

    -1熱度

    1回答

    我已經使用POCO C++庫用於實踐purposes.My反應器服務器當前工作正常設計的反應器中的服務器。 現在我想設計並聯電抗器服務器。這是我的並聯反應器的服務器的主要功能: 1.unsigned short port = 8080; 2.ServerSocket ServerSocket(port); 3.Timespan timeout(3000); 4.ParallelSocketR

    0熱度

    1回答

    今天我試着用下面的例子春天反應器:messaging-reactor 它基本上是從請求給定的URL隨機報價並打印出來到控制檯。這是一個很好的例子,可以說明出版和消費如何與彈簧反應器一起工作,而不會阻塞任何東西。 但我有一個小問題。在該例子中有定義一個接收器(消費者),並用一個輸出爲以下內容: Quote 4: Really loving Spring Boot, makes stand alone

    0熱度

    1回答

    我試圖發出值每秒爲 Flux.just(User("A"), User("B"), User("C")).delayElements(Duration.ofSeconds(1)) ,但它是在一次與啓動1秒的延遲發射的一切。我怎樣才能引入每個元素髮射的延遲?

    -6熱度

    2回答

    .NET庫中實現observer發佈 - 訂閱模式的類的名稱是什麼? 據我所知,Rx.NET與reactor pattern實施,並且有observer and reactor pattern之間的差異。選擇答案後 更新: 這個問題獲得3票關閉。我不知道是否是因爲這個問題沒有答案。這裏是我從回答中知道的,VáclavStruhár發佈和進一步閱讀。 Observable是許多框架和語言中使用的一個

    1熱度

    1回答

    我有一個簡單的控制器 @RestController @RequestMapping("path") public class MyController { @PostMapping(consumes = MediaType.APPLICATION_JSON_VALUE, produces = MediaType.APPLICATION_JSON_VALUE) publi

    1熱度

    1回答

    libuv用於處理IO的反應堆模式是按設計同步的,但libuv支持異步io。這怎麼可能? libuv是否以某種方式擴展了反應堆的設計以支持異步io?使用多線程/事件循環是否有助於實現這一目標?