Package org.processmining.specpp.supervision.piping

Class AbstractBufferingPipe<I extends Observation,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<I,O>

All Implemented Interfaces:

java.util.function.Consumer<I>, AsyncAwareObservable<O>, Buffering, Observable<O>, ObservationPipe<I,O>, Observer<I>, Triggerable

Direct Known Subclasses:

BufferPipe, SummarizingBufferPipe

public abstract class AbstractBufferingPipe<I extends Observation,O extends Observation>
extends AbstractAsyncAwareObservable<O>
implements ObservationPipe<I,O>, Buffering

Field Summary

Fields

Modifier and Type	Field	Description
protected Buffer<I>	buffer
boolean	hasThreadsafeBuffer

Constructor Summary

Constructors

Constructor	Description
AbstractBufferingPipe(boolean useThreadsafeBuffer)
AbstractBufferingPipe(Buffer<I> buffer)

Method Summary

Modifier and Type	Method	Description
protected void	buffer(I observation)
protected abstract O	collect(Observations<I> bufferedObservations)
protected ObservationCollection<I>	drainBuffer()
void	flushBuffer()
boolean	hasThreadsafeBuffer()
boolean	isBufferNonEmpty()
void	observe(I observation)

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.Buffering

trigger

Methods inherited from interface java.util.function.Consumer

andThen

Methods inherited from interface org.processmining.specpp.supervision.piping.Observable

addObserver, beObservedBy, clearObservers, getObservers, publish, removeObserver

Methods inherited from interface org.processmining.specpp.supervision.piping.Observer

accept

Field Detail

buffer

protected final Buffer<I extends Observation> buffer

hasThreadsafeBuffer

public final boolean hasThreadsafeBuffer

Constructor Detail

AbstractBufferingPipe

public AbstractBufferingPipe(boolean useThreadsafeBuffer)

AbstractBufferingPipe

public AbstractBufferingPipe(Buffer<I> buffer)

Method Detail

hasThreadsafeBuffer

public boolean hasThreadsafeBuffer()

buffer

protected void buffer(I observation)

collect

protected abstract O collect(Observations<I> bufferedObservations)

drainBuffer

protected ObservationCollection<I> drainBuffer()

flushBuffer

public void flushBuffer()

Specified by:

flushBuffer in interface Buffering

isBufferNonEmpty

public boolean isBufferNonEmpty()

Specified by:

isBufferNonEmpty in interface Buffering

observe

public void observe(I observation)

Specified by:

observe in interface Observer<I extends Observation>