AsyncAwareObservable (SPECpp)

All Superinterfaces:

Observable<O>

All Known Subinterfaces:

AdHocObservable<O>, AsyncAdHocObservable<O>, AsyncObservable<O>, AsyncObservationPipe<I,O>

All Known Implementing Classes:

AbstractAsyncAwareObservable, AbstractBufferingPipe, AccumulatingPipe, AccumulatingSummarizingPipe, ActionPipe, AdHocObservableWrapper, AsyncAdHocObservableWrapper, AsyncBufferPipe, AsyncEventSupervision, AsyncIdentityPipe, AsyncSummarizingBufferPipe, AsyncTransformingPipe, BufferPipe, ConcurrencyBridge, ConcurrentTimeStopper, CountingAsyncBufferPipe, CountingBufferPipe, DeflatingPipe, DelegatingAdHocObservable, DelegatingObservable, EventSupervision, FilterPipe, IdentityPipe, InflatingPipe, MergingSummarizingPipe, OngoingComputation, OngoingStagedComputation, PackingPipe, PredicatePipe, SelfEmptyingSummarizingBufferPipe, SkippingPipe, SummarizingBufferPipe, SummarizingPipe, TimeStopper, TransformingPipe, TreeDrawer, TreePrinter, TypeIdentTransformingPipe, UnpackingPipe
```
public interface AsyncAwareObservable<O extends Observation>
extends Observable<O>
```

Method Summary

All Methods Instance Methods Abstract Methods Default Methods
Modifier and Type	Method	Description
`java.util.List<AsyncObserver<O>>`	`getAsyncObservers()`
`java.util.List<Observer<O>>`	`getNonAsyncObservers()`
`default void`	`publishFutureToAsyncObservers(java.util.concurrent.CompletableFuture<O> futureObservation)`
`default void`	`publishFutureToNonAsyncObservers(java.util.concurrent.CompletableFuture<O> futureObservation)`

Methods inherited from interface org.processmining.specpp.supervision.piping.Observable
addObserver, beObservedBy, clearObservers, getObservers, publish, removeObserver

Method Detail

getAsyncObservers

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

getNonAsyncObservers

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

publishFutureToAsyncObservers

default void publishFutureToAsyncObservers(java.util.concurrent.CompletableFuture<O> futureObservation)

publishFutureToNonAsyncObservers

default void publishFutureToNonAsyncObservers(java.util.concurrent.CompletableFuture<O> futureObservation)