StreamMinFuture<T> class
Converts a Stream into a Future that completes with the smallest item emitted by the Stream.
This is similar to finding the min value in a list, but the values are asynchronous.
Example
int min = await new StreamMinFuture(new Stream.fromIterable([1, 2, 3]));
print(min); // prints 1
Example with custom Comparator
Stream<String> stream = new Stream.fromIterable("short", "loooooooong");
Comparator<String> stringLengthComparator = (a, b) => a.length - b.length;
String min = await new StreamMinFuture(stream, stringLengthComparator);
print(min); // prints "short"
- Inheritance
- Object
- WrappedFuture<
T> - StreamMinFuture
Constructors
-
StreamMinFuture(Stream<
T> stream, [ Comparator<T> comparator ])
Properties
- hashCode → int
-
The hash code for this object.
read-only, inherited
- runtimeType → Type
-
A representation of the runtime type of the object.
read-only, inherited
-
wrapped
→ Future<
T> -
final, inherited
Methods
-
asStream(
) → Stream< T> -
Creates a
Streamcontaining the result of this future. [...]inherited -
catchError(
Function onError, { bool test(Object error) }) → Future< T> -
Handles errors emitted by this
Future. [...]inherited -
noSuchMethod(
Invocation invocation) → dynamic -
Invoked when a non-existent method or property is accessed.
inherited
-
then<
S> (FutureOr< S> onValue(T value), { Function onError }) → Future<S> -
Register callbacks to be called when this future completes. [...]
inherited
-
timeout(
Duration timeLimit, { FutureOr< T> onTimeout() }) → Future<T> -
Time-out the future computation after
timeLimithas passed. [...]inherited -
toString(
) → String -
Returns a string representation of this object.
inherited
-
whenComplete(
void action()) → Future< T> -
Registers a function to be called when this future completes. [...]
inherited
Operators
-
operator ==(
dynamic other) → bool -
The equality operator.
inherited