streamAs<T> method

Stream<T> streamAs<T>()

Get a typed stream of messages for this subscription.

Example:

subscription.streamAs<Map<String, dynamic>>().listen((message) {
  print('User: ${message['user']}');
});

Implementation

Stream<T> streamAs<T>() => _messageStreamController.stream.cast<T>();