void sendData(List<int> bytes, {bool endStream = false}) { outgoingMessages.add(DataStreamMessage(bytes, endStream: endStream)); if (endStream) outgoingMessages.close(); }