diff --git a/packages/common/src/client/sync/stream/AbstractRemote.ts b/packages/common/src/client/sync/stream/AbstractRemote.ts index f0de66d00..7d67dad3f 100644 --- a/packages/common/src/client/sync/stream/AbstractRemote.ts +++ b/packages/common/src/client/sync/stream/AbstractRemote.ts @@ -310,10 +310,9 @@ export abstract class AbstractRemote { clearTimeout(keepAliveTimeout); keepAliveTimeout = setTimeout(() => { this.logger.error(`No data received on WebSocket in ${SOCKET_TIMEOUT_MS}ms, closing connection.`); - stream.close(); + stream?.close(); }, SOCKET_TIMEOUT_MS); }; - resetTimeout(); const url = this.options.socketUrlTransformer(request.url); const connector = new RSocketConnector({