class Await extends EventStreamBase<Try<T>> implements AwaitingEventStream<Try<T>> {

    public static <T> AwaitingEventStream<Try<T>> awaitTask(
            EventStream<Task<T>> source) {
        return new Await<>(source, Await::addCompletionHandler);
    }

    private  Await(
            EventStream<F> source,
            BiConsumer<F, TriConsumer<T, Throwable, Boolean>> addCompletionHandler);

}