onNextEmit<E extends T> method

Future<void> onNextEmit<E extends T>()
inherited

return Future that completes on the next event emitted of type E

auto clear from memory on complete you can use completeCompleters to complete and clear all onNextEmit completers from memory

Implementation

Future<void> onNextEmit<E extends T>() {
  final completer = Completer();
  handle<E>((event) => completer.complete());
  _completers.add(completer);
  return completer.future.then((_) {
    if (_ == null) _completers.remove(completer);
  });
}