Package org.processmining.specpp.supervision.piping

Class AsyncTransformingPipe<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.TransformingPipe<I,O>

org.processmining.specpp.supervision.piping.AsyncTransformingPipe<I,O>

All Implemented Interfaces:

java.util.function.Consumer<I>, AsyncAwareObservable<O>, AsyncObservable<O>, AsyncObservationPipe<I,O>, AsyncObserver<I>, Observable<O>, ObservationPipe<I,O>, Observer<I>

public class AsyncTransformingPipe<I extends Observation,O extends Observation>
extends TransformingPipe<I,O>
implements AsyncObservationPipe<I,O>

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AsyncTransformingPipe(ObservationTransformer<? super I,? extends O> transformer)

Method Summary

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

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

observe, toString, transform

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

AsyncTransformingPipe

protected AsyncTransformingPipe(ObservationTransformer<? super I,? extends O> transformer)

Method Detail

observeAsync

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

Specified by:

observeAsync in interface AsyncObserver<I extends Observation>