We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e962a73 commit 0edcf63Copy full SHA for 0edcf63
packages/firestore/src/platform/node/grpc_connection.ts
@@ -286,9 +286,15 @@ export class GrpcConnection implements Connection {
286
}
287
});
288
289
+ let onConnectedSent = false;
290
grpcStream.on('data', (msg: Resp) => {
291
if (!closed) {
292
logDebug(LOG_TAG, `RPC '${rpcName}' stream ${streamId} received:`, msg);
293
+ // Emulate the "onConnected" event that WebChannelConnection sends.
294
+ if (!onConnectedSent) {
295
+ stream.callOnConnected();
296
+ onConnectedSent = true;
297
+ }
298
stream.callOnMessage(msg);
299
300
0 commit comments