write method

void write(
  1. MessageStreamChunk chunk
)

Implementation

void write(MessageStreamChunk chunk) async {
  await _client.sendMessage(
    to: _to,
    type: "stream.chunk",
    message: {"stream_id": _streamId, "header": chunk.header},
    attachment: chunk.data,
  );
}