The ability to directly subscribe to receive messages.
final PublishSubject<Map<String, dynamic>> messageSubject = PublishSubject();