Class RecordPipeBufferedWrapper

java.lang.Object
com.kingsrook.qqq.backend.core.actions.reporting.RecordPipe
com.kingsrook.qqq.backend.core.actions.reporting.BufferedRecordPipe
com.kingsrook.qqq.backend.core.actions.reporting.RecordPipeBufferedWrapper
public class RecordPipeBufferedWrapper extends BufferedRecordPipe
Subclass of BufferedRecordPipe, which ultimately sends records down to an original RecordPipe. Meant to be used where: someone passed in a RecordPipe (so they have a reference to it, and they are waiting to read from it), but the producer knows that it will be better to buffer the records, so they want to use a buffered pipe (but they still need the records to end up in the original pipe - thus - it gets wrapped by an object of this class).

  • Constructor Details

    • RecordPipeBufferedWrapper

      public RecordPipeBufferedWrapper(RecordPipe wrappedPipe)
      Constructor - uses default buffer size

    • RecordPipeBufferedWrapper

      public RecordPipeBufferedWrapper(Integer bufferSize, RecordPipe wrappedPipe)
      Constructor - customize buffer size.

  • Method Details

    • flush

      protected void flush() throws QException
      when it's time to actually add records into the pipe (flushing from buffer int pipe), actually add them into the wrapped pipe!
      Overrides:
      flush in class BufferedRecordPipe
      Throws:
      QException

    • getWrappedPipe

      public RecordPipe getWrappedPipe()