AsyncIdentityPipe (SPECpp)

java.lang.Object
- org.processmining.specpp.supervision.piping.AbstractObservable<O>
- - org.processmining.specpp.supervision.piping.AbstractAsyncAwareObservable<O>
  - - org.processmining.specpp.supervision.piping.IdentityPipe<O>
    - - org.processmining.specpp.supervision.piping.AsyncIdentityPipe<O>

All Implemented Interfaces:

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

Direct Known Subclasses:

AsyncEventSupervision
```
public class AsyncIdentityPipe<O extends Observation>
extends IdentityPipe<O>
implements AsyncObservationPipe<O,O>
```

Constructor Summary

Constructors
Constructor Description

AsyncIdentityPipe()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`observe(O observation)`
`void`	`observeAsync(java.util.concurrent.CompletableFuture<O> futureObservation)`

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, toString, wait, wait, wait

Methods inherited from interface org.processmining.specpp.supervision.piping.AsyncAwareObservable
getAsyncObservers, getNonAsyncObservers, publishFutureToAsyncObservers, publishFutureToNonAsyncObservers

Methods inherited from interface org.processmining.specpp.supervision.piping.AsyncObservable
publishAsync

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

- Constructor Detail
  - AsyncIdentityPipe
```
public AsyncIdentityPipe()
```
- Method Detail
  - observe
```
public void observe(O observation)
```
    Specified by:
    
    observe in interface Observer<O extends Observation>
    
    Overrides:
    
    observe in class IdentityPipe<O extends Observation>
  - observeAsync
```
public void observeAsync(java.util.concurrent.CompletableFuture<O> futureObservation)
```
    Specified by:
    
    observeAsync in interface AsyncObserver<O extends Observation>