bunpy.node.stream

from bunpy.node import stream
from bunpy.node.stream import Readable, Writable, PassThrough

r = stream.Readable()
r.push(b"chunk 1")
r.push(b"chunk 2")
r.push(None)   # signal EOF

data = r.read()   # returns all buffered bytes

w = stream.Writable()
w.write(b"hello ")
w.write(b"world")
w.end()

content = w.getContents()   # b"hello world"

pt = stream.PassThrough()
pt.write(b"data")
pt.end()
out = pt.read()   # b"data"

src = stream.Readable()
src.push(b"hello")
src.push(None)

dst = stream.Writable()
src.pipe(dst)

print(dst.getContents())   # b"hello"

class UpperCase(stream.Transform):
    def _transform(self, chunk, encoding, callback):
        self.push(chunk.upper())
        callback()