diff --git a/src/Session.js b/src/Session.js index 0be7a90..df6ef22 100644 --- a/src/Session.js +++ b/src/Session.js @@ -35,10 +35,10 @@ export const MetaSession = RethinkdbWebsocketClient => { this._subscriptionManager = new SubscriptionManager(runQueryFn); } - connect({host, port, path, wsProtocols, secure, db, simulatedLatencyMs, autoReconnectDelayMs}) { + connect({host, port, path, wsProtocols, wsBinaryType, secure, db, simulatedLatencyMs, autoReconnectDelayMs}) { ensure(!this._connPromise, 'Session.connect() called when connected'); const connectAfterDelay = delayMs => { - const options = {host, port, path, wsProtocols, secure, db, simulatedLatencyMs}; + const options = {host, port, path, wsProtocols, wsBinaryType, secure, db, simulatedLatencyMs}; this._connPromise = new Promise((resolve, reject) => { setTimeout(() => { connect(options).then(resolve, reject);