takeFirst<T> method

Future<T> takeFirst<T>(
  1. Stream<T> stream
)

Implementation

Future<T> takeFirst<T>(Stream<T> stream) {
  final cmp = Completer<T>();
  late StreamSubscription subs;

  subs = each(stream, (item) {
    subs.cancel();
    cmp.complete(item);
  });

  return cmp.future;
}