takeFirst<T> method
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;
}