diff --git a/xchange-stream-bybit/src/test/java/info/bitrich/xchangestream/bybit/BybitStreamExample.java b/xchange-stream-bybit/src/test/java/info/bitrich/xchangestream/bybit/BybitStreamExample.java
index 3b508feb6d..86ce5da51c 100644
--- a/xchange-stream-bybit/src/test/java/info/bitrich/xchangestream/bybit/BybitStreamExample.java
+++ b/xchange-stream-bybit/src/test/java/info/bitrich/xchangestream/bybit/BybitStreamExample.java
@@ -155,7 +155,7 @@ public static void spot() throws IOException {
         exchange
             .getStreamingMarketDataService()
             .getOrderBook(ETH_SPOT)
-            .subscribe();
+            .subscribe());
     tradesDisposable.add(exchange
         .getStreamingMarketDataService().getTrades(ETH_SPOT).subscribe(
             trade -> System.out.println("trade: " + trade)));