Package org.processmining.specpp.componenting.delegators

Class DelegatingObservable<O extends Observation>

java.lang.Object

org.processmining.specpp.componenting.delegators.AbstractDelegator<AsyncAwareObservable<O>>

org.processmining.specpp.componenting.delegators.DelegatingObservable<O>

All Implemented Interfaces:

Container<AsyncAwareObservable<O>>, Delegator<AsyncAwareObservable<O>>, AsyncAwareObservable<O>, Observable<O>

public class DelegatingObservable<O extends Observation>
extends AbstractDelegator<AsyncAwareObservable<O>>
implements AsyncAwareObservable<O>

Field Summary

Fields inherited from class org.processmining.specpp.componenting.delegators.AbstractDelegator

delegate

Constructor Summary

Constructors

Constructor	Description
DelegatingObservable()
DelegatingObservable(AsyncAwareObservable<O> delegate)

Method Summary

Modifier and Type	Method	Description
void	addObserver(Observer<O> observer)
void	clearObservers()
java.util.List<AsyncObserver<O>>	getAsyncObservers()
java.util.List<Observer<O>>	getNonAsyncObservers()
java.util.Collection<Observer<O>>	getObservers()
void	publish(O observation)
void	removeObserver(Observer<O> observer)

Methods inherited from class org.processmining.specpp.componenting.delegators.AbstractDelegator

equals, getDelegate, hashCode, isSet, setDelegate, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

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

publishFutureToAsyncObservers, publishFutureToNonAsyncObservers

Methods inherited from interface org.processmining.specpp.componenting.delegators.Container

isNonEmpty

Methods inherited from interface org.processmining.specpp.componenting.delegators.Delegator

addContent, isEmpty, isFull

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

beObservedBy

Constructor Detail

DelegatingObservable

public DelegatingObservable()

DelegatingObservable

public DelegatingObservable(AsyncAwareObservable<O> delegate)

Method Detail

addObserver

public void addObserver(Observer<O> observer)

Specified by:

addObserver in interface Observable<O extends Observation>

getObservers

public java.util.Collection<Observer<O>> getObservers()

Specified by:

getObservers in interface Observable<O extends Observation>

removeObserver

public void removeObserver(Observer<O> observer)

Specified by:

removeObserver in interface Observable<O extends Observation>

clearObservers

public void clearObservers()

Specified by:

clearObservers in interface Observable<O extends Observation>

publish

public void publish(O observation)

Specified by:

publish in interface Observable<O extends Observation>

getAsyncObservers

public java.util.List<AsyncObserver<O>> getAsyncObservers()

Specified by:

getAsyncObservers in interface AsyncAwareObservable<O extends Observation>

getNonAsyncObservers

public java.util.List<Observer<O>> getNonAsyncObservers()

Specified by:

getNonAsyncObservers in interface AsyncAwareObservable<O extends Observation>