fix: await initial pushable read (#109)

Without this the first write to a byte/length-prefixed or protobuf stream doesn't wait for the message to be read.
achingbrain · Dec 2, 2023 · 011fb6b · 011fb6b
1 parent c7bf5e3
commit 011fb6b
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/packages/it-byte-stream/src/pushable.ts b/packages/it-byte-stream/src/pushable.ts
@@ -27,8 +27,6 @@ class QueuelessPushable <T> implements Pushable<T> {
     this.ended = false
 
     this.needNext = deferred()
-    this.needNext.resolve()
-
     this.haveNext = deferred()
   }