Uses of Interface
org.bsc.async.AsyncGenerator
-
-
Uses of AsyncGenerator in org.bsc.async
Classes in org.bsc.async that implement AsyncGenerator Modifier and Type Class Description static classAsyncGenerator.WithEmbed<E>An asynchronous generator decorator that allows to generators composition embedding other generators.static classAsyncGenerator.WithResult<E>An asynchronous generator decorator that allows retrieving the result value of the asynchronous operation, if any.static classAsyncGeneratorQueue.Generator<E>Inner class to generate asynchronous elements from the queue.Fields in org.bsc.async declared as AsyncGenerator Modifier and Type Field Description protected AsyncGenerator<E>AsyncGenerator.WithResult. delegateMethods in org.bsc.async that return AsyncGenerator Modifier and Type Method Description static <E,U>
AsyncGenerator<U>AsyncGenerator. collect(Collection<E> collection, BiConsumer<E,Consumer<CompletableFuture<U>>> consumer)Collects asynchronous elements from a collection.static <E,U>
AsyncGenerator<U>AsyncGenerator. collect(Iterator<E> iterator, BiConsumer<E,Consumer<CompletableFuture<U>>> consumer)Collects asynchronous elements from an iterator.AsyncGenerator<E>AsyncGenerator.WithResult. delegate()static <E> AsyncGenerator<E>AsyncGenerator. empty()Returns an empty AsyncGenerator.static <E,U>
AsyncGenerator<U>AsyncGenerator. map(Collection<E> collection, Function<E,CompletableFuture<U>> mapFunction)create a generator, mapping each element to an asynchronous counterpart.static <E,U>
AsyncGenerator<U>AsyncGenerator. map(Iterator<E> iterator, Function<E,CompletableFuture<U>> mapFunction)create a generator, mapping each element to an asynchronous counterpart.static <E,Q extends BlockingQueue<AsyncGenerator.Data<E>>>
AsyncGenerator<E>AsyncGeneratorQueue. of(Q queue, Executor executor, Consumer<Q> consumer)Deprecated.use of(Q, Consumer, Executor)static <E,Q extends BlockingQueue<AsyncGenerator.Data<E>>>
AsyncGenerator<E>AsyncGeneratorQueue. of(Q queue, Consumer<Q> consumer)Creates an AsyncGenerator from the provided blocking queue and consumer.static <E,Q extends BlockingQueue<AsyncGenerator.Data<E>>>
AsyncGenerator<E>AsyncGeneratorQueue. of(Q queue, Consumer<Q> consumer, Executor executor)Creates an AsyncGenerator from the provided queue, executor, and consumer.Methods in org.bsc.async with parameters of type AsyncGenerator Modifier and Type Method Description static <E> AsyncGenerator.Data<E>AsyncGenerator.Data. composeWith(AsyncGenerator<E> generator, AsyncGenerator.EmbedCompletionHandler onCompletion)Constructors in org.bsc.async with parameters of type AsyncGenerator Constructor Description Embed(AsyncGenerator<E> generator, AsyncGenerator.EmbedCompletionHandler onCompletion)WithEmbed(AsyncGenerator<E> delegate)WithEmbed(AsyncGenerator<E> delegate, AsyncGenerator.EmbedCompletionHandler onGeneratorDoneWithResult)WithResult(AsyncGenerator<E> delegate)
-