[gateio-stream] Speed up integration tests

knowm · Apr 26, 2024 · a831d5a · a831d5a
1 parent 097943d
commit a831d5a
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git a/...test/java/info/bitrich/xchangestream/gateio/GateioStreamingAccountServiceIntegration.java b/...test/java/info/bitrich/xchangestream/gateio/GateioStreamingAccountServiceIntegration.java
@@ -33,7 +33,7 @@ void spot_balances() {
 
     Balance balance = testObserver
         .assertSubscribed()
-        .awaitCount(1, TestWaitStrategy.SLEEP_10MS, 2000000)
+        .awaitCount(1, TestWaitStrategy.SPIN, 2000000)
         .assertNoTimeout()
         .values().get(0);
 

diff --git a/...t/java/info/bitrich/xchangestream/gateio/GateioStreamingMarketDataServiceIntegration.java b/...t/java/info/bitrich/xchangestream/gateio/GateioStreamingMarketDataServiceIntegration.java
@@ -24,7 +24,7 @@ void order_book() {
 
     OrderBook orderBook = testObserver
         .assertSubscribed()
-        .awaitCount(1, TestWaitStrategy.SLEEP_10MS, 20000)
+        .awaitCount(1, TestWaitStrategy.SPIN, 20000)
         .assertNoTimeout()
         .values().get(0);
 
@@ -49,7 +49,7 @@ void trades() {
 
     Trade trade = testObserver
         .assertSubscribed()
-        .awaitCount(1, TestWaitStrategy.SLEEP_10MS, 20000)
+        .awaitCount(1, TestWaitStrategy.SPIN, 20000)
         .assertNoTimeout()
         .values().get(0);
 
@@ -71,7 +71,7 @@ void ticker() {
 
     Ticker ticker = testObserver
         .assertSubscribed()
-        .awaitCount(1, TestWaitStrategy.SLEEP_10MS, 70000)
+        .awaitCount(1, TestWaitStrategy.SPIN, 70000)
         .assertNoTimeout()
         .values()
         .get(0);

diff --git a/...c/test/java/info/bitrich/xchangestream/gateio/GateioStreamingTradeServiceIntegration.java b/...c/test/java/info/bitrich/xchangestream/gateio/GateioStreamingTradeServiceIntegration.java
@@ -33,7 +33,7 @@ void user_trades_btc() {
 
     UserTrade userTrade = testObserver
         .assertSubscribed()
-        .awaitCount(1, TestWaitStrategy.SLEEP_10MS, 2000000)
+        .awaitCount(1, TestWaitStrategy.SPIN, 2000000)
         .assertNoTimeout()
         .values().get(0);
 
@@ -54,7 +54,7 @@ void user_trades_all() {
 
     UserTrade userTrade = testObserver
         .assertSubscribed()
-        .awaitCount(1, TestWaitStrategy.SLEEP_10MS, 2000000)
+        .awaitCount(1, TestWaitStrategy.SPIN, 2000000)
         .assertNoTimeout()
         .values().get(0);