Package org.processmining.specpp.supervision.piping

Class AccumulatingPipe<O extends Observation & Mergeable<? super O>>

java.lang.Object

org.processmining.specpp.supervision.piping.AbstractObservable<O>

org.processmining.specpp.supervision.piping.AbstractAsyncAwareObservable<O>

org.processmining.specpp.supervision.piping.TransformingPipe<O,O>

org.processmining.specpp.supervision.piping.TypeIdentTransformingPipe<O>

org.processmining.specpp.supervision.piping.AccumulatingPipe<O>

All Implemented Interfaces:

java.util.function.Consumer<O>, AsyncAwareObservable<O>, Observable<O>, ObservationPipe<O,O>, Observer<O>, TypeIdentPipe<O>, DimensionalityTrait, FromOne<O>, OneToOne<O,O>, ToOne<O>

public class AccumulatingPipe<O extends Observation & Mergeable<? super O>>
extends TypeIdentTransformingPipe<O>
implements OneToOne<O,O>

Constructor Summary

Constructors

Constructor	Description
AccumulatingPipe(java.util.function.Supplier<O> initial)

Method Summary

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

publishFutureToAsyncObservers, publishFutureToNonAsyncObservers

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

AccumulatingPipe

public AccumulatingPipe(java.util.function.Supplier<O> initial)