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 Summary

Constructors

Constructor	Description
RecordPipeBufferedWrapper(RecordPipe wrappedPipe)	Constructor - uses default buffer size
RecordPipeBufferedWrapper(Integer bufferSize, RecordPipe wrappedPipe)	Constructor - customize buffer size.

Method Summary

Modifier and Type	Method	Description
void	addRecords(List<QRecord> records)	when it's time to actually add records into the pipe, actually add them into the wrapped pipe!

Methods inherited from class com.kingsrook.qqq.backend.core.actions.reporting.BufferedRecordPipe

addRecord, finalFlush

Methods inherited from class com.kingsrook.qqq.backend.core.actions.reporting.RecordPipe

consumeAvailableRecords, countAvailableRecords, getCapacity, setPostRecordActions, terminate

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

addRecords

public void addRecords(List<QRecord> records)
                throws QException

when it's time to actually add records into the pipe, actually add them into the wrapped pipe!

Overrides:

addRecords in class RecordPipe

Throws:

QException