Stream of messages received from the transport
@override Stream<Map<String, dynamic>> get messageStream => _messageController.stream;