add disconnect to StreamConnection

Author: theo-s68

clients/common/src/main/java/com/binance/connector/client/common/websocket/adapter/stream/StreamConnectionInterface.java

@@ -16,6 +16,8 @@ Map<String, StreamBlockingQueue<String>> subscribe(
 
     void connect();
 
+    void disconnect();
+
     boolean isConnected();
 
     void setUserAgent(String userAgent);

clients/common/src/main/java/com/binance/connector/client/common/websocket/adapter/stream/StreamConnectionPoolWrapper.java

@@ -84,6 +84,14 @@ public void connect() {
         isConnected = true;
     }
 
+    @Override
+    public void disconnect() {
+        for (ConnectionWrapper connectionWrapper : connectionList) {
+            connectionWrapper.disconnect();
+        }
+        isConnected = false;
+    }
+
     public Map<String, StreamBlockingQueue<String>> subscribe(
             RequestWrapperDTO<Set<String>, Object> requestWrapperDTO) {
         Set<String> params = requestWrapperDTO.getParams();