anchor.diff:  
     /// Receive timer duration
     const Duration rxDuration = const Duration(seconds: 10);
  +
  +  /// Received message stream
  +  final _messageRxed = new StreamController.broadcast();
  +  get nextMessage => _messageRxed.stream;
   
     /// Dartivity
     /// mode - the operational mode of the client
  
positive.code:     String messageString = message.asString;
      DartivityMessage dartivityMessage =
          new DartivityMessage.fromJSON(messageString);
    }
  }
  
negative.code:     _messager.send(jsonMessage);
    }
  
    /// _receive
    ///
    /// Message receive method
    Future _receive(Timer timer) async {
  