Class QueueInputStream.Builder

All Implemented Interfaces:
IOSupplier<QueueInputStream>
Enclosing class:
QueueInputStream

public static class QueueInputStream.Builder extends AbstractStreamBuilder<QueueInputStream,QueueInputStream.Builder>
Builds a new QueueInputStream instance.

For example:


 QueueInputStream s = QueueInputStream.builder()
   .setBlockingQueue(new LinkedBlockingQueue<>())
   .setTimeout(Duration.ZERO)
   .get();
 
Since:
2.12.0
  • Field Details

  • Constructor Details

    • Builder

      public Builder()
  • Method Details

    • get

      public QueueInputStream get()
      Constructs a new instance.

      This builder use the aspects BlockingQueue and timeout.

      Returns:
      a new instance.
    • setBlockingQueue

      public QueueInputStream.Builder setBlockingQueue(BlockingQueue<Integer> blockingQueue)
      Sets backing queue for the stream.
      Parameters:
      blockingQueue - backing queue for the stream.
      Returns:
      this
    • setTimeout

      public QueueInputStream.Builder setTimeout(Duration timeout)
      Sets the polling timeout.
      Parameters:
      timeout - the polling timeout.
      Returns:
      this.