void configure(Stream<String> inStream, void Function(String) writeMessage) { _streamSub = inStream.listen(_processMessage); _writeMessage = writeMessage; }