on method

StreamSubscription on(
  1. QueueEventAction action,
  2. void event(
    1. QueueEvent
    )
)

Implementation

StreamSubscription on(QueueEventAction action, void Function(QueueEvent) event) {
  return _eventStream
    .where((event) => event.action == action)
    .listen(event);
}