Class CountingAsyncBufferPipe<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>
-
- org.processmining.specpp.supervision.piping.AsyncBufferPipe<O>
-
- org.processmining.specpp.supervision.piping.CountingAsyncBufferPipe<O>
-
- All Implemented Interfaces:
java.util.function.Consumer<O>,AsyncAwareObservable<Observations<O>>,AsyncObservable<Observations<O>>,AsyncObservationPipe<O,Observations<O>>,AsyncObserver<O>,Buffering,Observable<Observations<O>>,ObservationPipe<O,Observations<O>>,Observer<O>,DimensionalityTrait,FromOne<O>,OneToMany<O,O>,ToMany<O>,Triggerable
public class CountingAsyncBufferPipe<O extends Observation> extends AsyncBufferPipe<O>
-
-
Field Summary
-
Fields inherited from class org.processmining.specpp.supervision.piping.AbstractBufferingPipe
buffer, hasThreadsafeBuffer
-
-
Constructor Summary
Constructors Constructor Description CountingAsyncBufferPipe(int threshold)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected voidbuffer(O observation)-
Methods inherited from class org.processmining.specpp.supervision.piping.AsyncBufferPipe
observeAsync, trigger
-
Methods inherited from class org.processmining.specpp.supervision.piping.BufferPipe
collect
-
Methods inherited from class org.processmining.specpp.supervision.piping.AbstractBufferingPipe
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
getAsyncObservers, getNonAsyncObservers, publishFutureToAsyncObservers, publishFutureToNonAsyncObservers
-
Methods inherited from interface org.processmining.specpp.supervision.piping.AsyncObservable
publishAsync
-
Methods inherited from interface org.processmining.specpp.supervision.piping.Observable
addObserver, beObservedBy, clearObservers, getObservers, publish, removeObserver
-
-
-
-
Method Detail
-
buffer
protected void buffer(O observation)
- Overrides:
bufferin classAbstractBufferingPipe<O extends Observation,Observations<O extends Observation>>
-
-