Class AsyncSummarizingBufferPipe<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>
-
- org.processmining.specpp.supervision.piping.SummarizingBufferPipe<I,O>
-
- org.processmining.specpp.supervision.piping.AsyncSummarizingBufferPipe<I,O>
-
- All Implemented Interfaces:
java.util.function.Consumer<I>,AsyncAwareObservable<O>,AsyncObservable<O>,AsyncObservationPipe<I,O>,AsyncObserver<I>,Buffering,Observable<O>,ObservationPipe<I,O>,Observer<I>,Triggerable
public class AsyncSummarizingBufferPipe<I extends Observation,O extends Observation> extends SummarizingBufferPipe<I,O> implements AsyncObservationPipe<I,O>
-
-
Field Summary
-
Fields inherited from class org.processmining.specpp.supervision.piping.AbstractBufferingPipe
buffer, hasThreadsafeBuffer
-
-
Constructor Summary
Constructors Constructor Description AsyncSummarizingBufferPipe(ObservationSummarizer<I,O> collator)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidobserveAsync(java.util.concurrent.CompletableFuture<I> futureObservation)voidtrigger()-
Methods inherited from class org.processmining.specpp.supervision.piping.SummarizingBufferPipe
collect
-
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
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
-
-
-
-
Constructor Detail
-
AsyncSummarizingBufferPipe
public AsyncSummarizingBufferPipe(ObservationSummarizer<I,O> collator)
-
-
Method Detail
-
observeAsync
public void observeAsync(java.util.concurrent.CompletableFuture<I> futureObservation)
- Specified by:
observeAsyncin interfaceAsyncObserver<I extends Observation>
-
trigger
public void trigger()
- Specified by:
triggerin interfaceBuffering- Specified by:
triggerin interfaceTriggerable
-
-