Class BufferPipe<O extends Observation>
- java.lang.Object
-
- org.processmining.specpp.supervision.piping.AbstractObservable<O>
-
- org.processmining.specpp.supervision.piping.AbstractAsyncAwareObservable<O>
-
- org.processmining.specpp.supervision.piping.AbstractBufferingPipe<O,Observations<O>>
-
- org.processmining.specpp.supervision.piping.BufferPipe<O>
-
- All Implemented Interfaces:
java.util.function.Consumer<O>,AsyncAwareObservable<Observations<O>>,Buffering,Observable<Observations<O>>,ObservationPipe<O,Observations<O>>,Observer<O>,DimensionalityTrait,FromOne<O>,OneToMany<O,O>,ToMany<O>,Triggerable
- Direct Known Subclasses:
AsyncBufferPipe,CountingBufferPipe
public class BufferPipe<O extends Observation> extends AbstractBufferingPipe<O,Observations<O>> implements OneToMany<O,O>
-
-
Field Summary
-
Fields inherited from class org.processmining.specpp.supervision.piping.AbstractBufferingPipe
buffer, hasThreadsafeBuffer
-
-
Constructor Summary
Constructors Constructor Description BufferPipe()BufferPipe(boolean useConcurrentBuffer)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected Observations<O>collect(Observations<O> bufferedObservations)-
Methods inherited from class org.processmining.specpp.supervision.piping.AbstractBufferingPipe
buffer, drainBuffer, flushBuffer, hasThreadsafeBuffer, isBufferNonEmpty, observe
-
Methods inherited from class org.processmining.specpp.supervision.piping.AbstractAsyncAwareObservable
addObserver, getAsyncObservers, getNonAsyncObservers
-
Methods inherited from class org.processmining.specpp.supervision.piping.AbstractObservable
clearObservers, getObservers, publish, removeObserver
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.processmining.specpp.supervision.piping.AsyncAwareObservable
publishFutureToAsyncObservers, publishFutureToNonAsyncObservers
-
Methods inherited from interface org.processmining.specpp.supervision.piping.Observable
addObserver, beObservedBy, clearObservers, getObservers, publish, removeObserver
-
-
-
-
Method Detail
-
collect
protected Observations<O> collect(Observations<O> bufferedObservations)
- Specified by:
collectin classAbstractBufferingPipe<O extends Observation,Observations<O extends Observation>>
-
-