From 767ea0700ea9a43c1992d667b491fd6830cbb042 Mon Sep 17 00:00:00 2001 From: achingbrain Date: Sat, 2 Dec 2023 07:42:06 +0000 Subject: [PATCH] fix: await intial pushable read Without this the first write to a byte/length-prefixed or protobuf stream doesn't wait for the message to be read. --- packages/it-byte-stream/src/pushable.ts | 2 -- 1 file changed, 2 deletions(-) diff --git a/packages/it-byte-stream/src/pushable.ts b/packages/it-byte-stream/src/pushable.ts index c3ab174e..cbc50b66 100644 --- a/packages/it-byte-stream/src/pushable.ts +++ b/packages/it-byte-stream/src/pushable.ts @@ -27,8 +27,6 @@ class QueuelessPushable implements Pushable { this.ended = false this.needNext = deferred() - this.needNext.resolve() - this.haveNext = deferred() }