onAs<T> method

  1. @override
Stream<T> onAs<T>(
  1. String eventName, {
  2. required T parser(
    1. dynamic json
    ),
})
override

Listens to events broadcasted under eventName and parses them with parser.

Implementation

@override
Stream<T> onAs<T>(
  String eventName, {
  required T Function(dynamic json) parser,
}) {
  return on(eventName).transform(
    StreamTransformer<dynamic, T>.fromHandlers(
      handleData: (data, sink) {
        sink.add(parser(data));
      },
    ),
  );
}