Method write

tests/dirty/test_worker_streaming.py:31–32

(self, data)

        self._buffer = b""

    def write(self, data):
        self._buffer += data

    async def drain(self):
        # Decode the buffer to extract messages using binary protocol