MCPcopy
hub / github.com/nestjs/nest / complete

Method complete

packages/microservices/server/server-grpc.ts:436–445  ·  packages/microservices/server/server-grpc.ts::ServerGrpc.complete
()

Source from the content-addressed store, hash-verified

434 }
435 },
436 complete() {
437 if (valuesWaitingToBeDrained.length === 0) {
438 class="cm">// We're not waiting for a drain event, so we can just
439 class="cm">// resolve and teardown.
440 subscription.unsubscribe();
441 resolve();
442 } else {
443 shouldResolveAfterDraining = true;
444 }
445 },
446 }),
447 );
448 });

Callers 12

createObserverFunction · 0.45
bufferUntilDrainedMethod · 0.45
sseBurstMethod · 0.45
streamLargeMessagesMethod · 0.45
streamMethod · 0.45
streamReqMethod · 0.45
getManyMethod · 0.45
onCompleteMethod · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected