Skip to content
4 changes: 3 additions & 1 deletion package-lock.json

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

5 changes: 5 additions & 0 deletions packages/channels/base/src/BlockStreamer.ts
Original file line number Diff line number Diff line change
Expand Up @@ -66,6 +66,11 @@ export class BlockStreamer {
this.buffer = '';
}

/** Await sends that were queued before this call. */
drain(): Promise<void> {
return this.sending;
}

// ---------------------------------------------------------------------------
// Internal
// ---------------------------------------------------------------------------
Expand Down
Loading
Loading