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 org.processmining.specpp.supervision.piping.Observable
addObserver, beObservedBy, clearObservers, getObservers, publish, removeObserver
-
-
-
-
Constructor Detail
-
AccumulatingPipe
public AccumulatingPipe(java.util.function.Supplier<O> initial)
-
-