Package org.processmining.specpp.supervision.piping

Class AdHocObservableWrapper<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.AdHocObservableWrapper<O>

All Implemented Interfaces:

AdHocObservable<O>, AsyncAwareObservable<O>, Observable<O>, Triggerable

Direct Known Subclasses:

AsyncAdHocObservableWrapper

public class AdHocObservableWrapper<O extends Observation>
extends AbstractAsyncAwareObservable<O>
implements AdHocObservable<O>

Constructor Summary

Constructors

Constructor	Description
AdHocObservableWrapper(java.util.function.Supplier<O> supplier)

Method Summary

Modifier and Type	Method	Description
O	computeObservation()
static <O extends Observation> AdHocObservableWrapper<O>	wrap(java.util.function.Supplier<O> supplier)

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

trigger

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

getAsyncObservers, getNonAsyncObservers, publishFutureToAsyncObservers, publishFutureToNonAsyncObservers

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

addObserver, beObservedBy, clearObservers, getObservers, publish, removeObserver

Constructor Detail

AdHocObservableWrapper

public AdHocObservableWrapper(java.util.function.Supplier<O> supplier)

Method Detail

wrap

public static <O extends Observation> AdHocObservableWrapper<O> wrap(java.util.function.Supplier<O> supplier)

computeObservation

public O computeObservation()

Specified by:

computeObservation in interface AdHocObservable<O extends Observation>