Module async.generator
Package org.bsc.async

Interface AsyncGeneratorQueue

@Deprecated(since="5.0.0", forRemoval=true) public interface AsyncGeneratorQueue
Deprecated, for removal: This API element is subject to removal in a future version.
use AsyncGeneratorFlow instead
Represents a queue-based asynchronous generator.

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Interface
    Description
    static class 
    AsyncGeneratorQueue.Generator<E>
    Deprecated, for removal: This API element is subject to removal in a future version.
    Inner class to generate asynchronous elements from the queue.

  • Method Summary

    Modifier and Type
    Method
    Description
    static <E, Q extends BlockingQueue<AsyncGenerator.Data<E>>>
    AsyncGenerator<E>
    of(Q queue, Consumer<Q> consumer)
    Deprecated, for removal: This API element is subject to removal in a future version.
    Creates an AsyncGenerator from the provided blocking queue and consumer.
    static <E, Q extends BlockingQueue<AsyncGenerator.Data<E>>>
    AsyncGenerator<E>
    of(Q queue, Consumer<Q> consumer, Executor executor)
    Deprecated, for removal: This API element is subject to removal in a future version.
    Creates an AsyncGenerator from the provided queue, executor, and consumer.

  • Method Details

    • of

      static <E, Q extends BlockingQueue<AsyncGenerator.Data<E>>> AsyncGenerator<E> of(Q queue, Consumer<Q> consumer)
      Deprecated, for removal: This API element is subject to removal in a future version.
      Creates an AsyncGenerator from the provided blocking queue and consumer.
      Type Parameters:
      E - the type of elements in the queue
      Q - the type of blocking queue
      Parameters:
      queue - the blocking queue to generate elements from
      consumer - the consumer for processing elements from the queue
      Returns:
      an AsyncGenerator instance

    • of

      static <E, Q extends BlockingQueue<AsyncGenerator.Data<E>>> AsyncGenerator<E> of(Q queue, Consumer<Q> consumer, Executor executor)
      Deprecated, for removal: This API element is subject to removal in a future version.
      Creates an AsyncGenerator from the provided queue, executor, and consumer.
      Type Parameters:
      E - the type of elements in the queue
      Q - the type of blocking queue
      Parameters:
      queue - the blocking queue to generate elements from
      consumer - the consumer for processing elements from the queue
      executor - the executor for asynchronous processing
      Returns:
      an AsyncGenerator instance