Method write

tests/test_dirty_worker.py:61–62

(self, data)

        self.closed = False

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

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