diff --git a/libp2p/stream/bufferstream.nim b/libp2p/stream/bufferstream.nim index 39934eb..21605f6 100644 --- a/libp2p/stream/bufferstream.nim +++ b/libp2p/stream/bufferstream.nim @@ -167,6 +167,9 @@ method pushTo*(s: BufferStream, data: seq[byte]) {.base, async.} = ## is preserved. ## + if s.atEof: + raise newLPStreamEOFError() + if s.atEof: raise newLPStreamEOFError()