onNextEmit<E extends T> method
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);
});
}