Method subscribeCombined

src/node-binance-api.ts:1490–1533

* Used to subscribe to a combined websocket endpoint * @param {string} streams - streams to connect to * @param {function} callback - the function to call when information is received * @param {boolean} reconnect - whether to reconnect on disconnect * @param {object} opened_callb

(streams: any, callback: Callback, reconnect?: Callback, opened_callback?: Callback)

     * @return {WebSocket} - websocket reference
     */
    subscribeCombined(streams: any, callback: Callback, reconnect?: Callback, opened_callback?: Callback) {
        const httpsproxy = this.getHttpsProxy();
        let socksproxy = this.getSocksProxy();
        const queryParams = streams.join('/');
        let ws: any = undefined;
        if (socksproxy) {
            socksproxy = this.proxyReplacewithIp(socksproxy);
            if (this.Options.verbose) this.Options.log('using socks proxy server ' + socksproxy);
            const agent = new SocksProxyAgent({
                protocol: this.parseProxy(socksproxy)[0],
                host: this.parseProxy(socksproxy)[1],
                port: this.parseProxy(socksproxy)[2]
            });
            ws = new WebSocket(this.getCombineStreamUrl() + queryParams, { agent: agent });
        } else if (httpsproxy) {
            if (this.Options.verbose) this.Options.log('using proxy server ' + httpsproxy);
            const config = url.parse(httpsproxy);
            const agent = new HttpsProxyAgent(config);
            ws = new WebSocket(this.getCombineStreamUrl() + queryParams, { agent: agent });
        } else {
            ws = new WebSocket(this.getCombineStreamUrl() + queryParams);
        }

        ws.reconnect = this.Options.reconnect;
        ws.endpoint = stringHash(queryParams);
        ws.isAlive = false;
        if (this.Options.verbose) {
            this.Options.log('CombinedStream: Subscribed to [' + ws.endpoint + '] ' + queryParams);
        }
        ws.on('open', this.handleSocketOpen.bind(this, ws, opened_callback));
        ws.on('pong', this.handleSocketHeartbeat.bind(this, ws));
        ws.on('error', this.handleSocketError.bind(this, ws));
        ws.on('close', this.handleSocketClose.bind(this, ws, reconnect));
        ws.on('message', data => {
            try {
                if (this.Options.verbose) this.Options.log('CombinedStream: WebSocket data:', data
                );
                callback(JSONbig.parse(data).data);
            } catch (error) {
                this.Options.log('CombinedStream: Parse error: ' + error.message);
            }
        });
        return ws;
    }

    /**
     * Used to terminate a web socket