Package org.processmining.specpp.supervision.piping

Class AsyncBufferPipe<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>

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

Direct Known Subclasses:

CountingAsyncBufferPipe

public class AsyncBufferPipe<O extends Observation>
extends BufferPipe<O>
implements AsyncObservationPipe<O,Observations<O>>, OneToMany<O,O>

Field Summary

Fields inherited from class org.processmining.specpp.supervision.piping.AbstractBufferingPipe

buffer, hasThreadsafeBuffer

Constructor Summary

Constructors

Constructor	Description
AsyncBufferPipe()

Method Summary

Modifier and Type	Method	Description
void	observeAsync(java.util.concurrent.CompletableFuture<O> futureObservation)
void	trigger()

Methods inherited from class org.processmining.specpp.supervision.piping.BufferPipe

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 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, observe

Constructor Detail

AsyncBufferPipe

public AsyncBufferPipe()

Method Detail

trigger

public void trigger()

Specified by:

trigger in interface Buffering

Specified by:

trigger in interface Triggerable

observeAsync

public void observeAsync(java.util.concurrent.CompletableFuture<O> futureObservation)

Specified by:

observeAsync in interface AsyncObserver<O extends Observation>