Package org.processmining.specpp.componenting.delegators

Class DelegatingObservationPipe<O extends Observation,C extends Observation>

java.lang.Object

org.processmining.specpp.componenting.delegators.AbstractDelegator<ObservationPipe<O,C>>

org.processmining.specpp.componenting.delegators.DelegatingObservationPipe<O,C>

All Implemented Interfaces:

java.util.function.Consumer<O>, Container<ObservationPipe<O,C>>, Delegator<ObservationPipe<O,C>>, Observable<C>, ObservationPipe<O,C>, Observer<O>

public class DelegatingObservationPipe<O extends Observation,C extends Observation>
extends AbstractDelegator<ObservationPipe<O,C>>
implements ObservationPipe<O,C>

Field Summary

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

delegate

Constructor Summary

Constructors

Constructor	Description
DelegatingObservationPipe()
DelegatingObservationPipe(ObservationPipe<O,C> delegate)

Method Summary

Modifier and Type	Method	Description
void	addObserver(Observer<C> observer)
void	clearObservers()
java.util.Collection<Observer<C>>	getObservers()
void	observe(O observation)
void	publish(C observation)
void	removeObserver(Observer<C> 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 java.util.function.Consumer

andThen

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

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

accept

Constructor Detail

DelegatingObservationPipe

public DelegatingObservationPipe()

DelegatingObservationPipe

public DelegatingObservationPipe(ObservationPipe<O,C> delegate)

Method Detail

addObserver

public void addObserver(Observer<C> observer)

Specified by:

addObserver in interface Observable<O extends Observation>

getObservers

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

Specified by:

getObservers in interface Observable<O extends Observation>

removeObserver

public void removeObserver(Observer<C> 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(C observation)

Specified by:

publish in interface Observable<O extends Observation>

observe

public void observe(O observation)

Specified by:

observe in interface Observer<O extends Observation>