Class AbstractAsyncAwareObservable<O extends Observation>
- java.lang.Object
-
- org.processmining.specpp.supervision.piping.AbstractObservable<O>
-
- org.processmining.specpp.supervision.piping.AbstractAsyncAwareObservable<O>
-
- All Implemented Interfaces:
AsyncAwareObservable<O>,Observable<O>
- Direct Known Subclasses:
AbstractBufferingPipe,AdHocObservableWrapper,ConcurrencyBridge,ConcurrentTimeStopper,IdentityPipe,InflatingPipe,OngoingComputation,TimeStopper,TransformingPipe,TreeDrawer,TreePrinter
public class AbstractAsyncAwareObservable<O extends Observation> extends AbstractObservable<O> implements AsyncAwareObservable<O>
-
-
Constructor Summary
Constructors Constructor Description AbstractAsyncAwareObservable()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaddObserver(Observer<O> observer)java.util.List<AsyncObserver<O>>getAsyncObservers()java.util.List<Observer<O>>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
publishFutureToAsyncObservers, publishFutureToNonAsyncObservers
-
Methods inherited from interface org.processmining.specpp.supervision.piping.Observable
beObservedBy, clearObservers, getObservers, publish, removeObserver
-
-
-
-
Method Detail
-
addObserver
public void addObserver(Observer<O> observer)
- Specified by:
addObserverin interfaceObservable<O extends Observation>- Overrides:
addObserverin classAbstractObservable<O extends Observation>
-
getAsyncObservers
public java.util.List<AsyncObserver<O>> getAsyncObservers()
- Specified by:
getAsyncObserversin interfaceAsyncAwareObservable<O extends Observation>
-
getNonAsyncObservers
public java.util.List<Observer<O>> getNonAsyncObservers()
- Specified by:
getNonAsyncObserversin interfaceAsyncAwareObservable<O extends Observation>
-
-