ConcurrencyBridge (SPECpp)

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

All Implemented Interfaces:

java.util.function.Consumer<O>, AsyncAwareObservable<O>, Observable<O>, ObservationPipe<O,O>, Observer<O>, TypeIdentPipe<O>, RequiresSupportingTask
```
public class ConcurrencyBridge<O extends Observation>
extends AbstractAsyncAwareObservable<O>
implements TypeIdentPipe<O>, RequiresSupportingTask
```

Constructor Summary

Constructors
Constructor Description

ConcurrencyBridge()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`java.lang.Runnable`	`getSupportingTask()`
`void`	`observe(O observation)`
`java.lang.String`	`toString()`

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

- Constructor Detail
  - ConcurrencyBridge
```
public ConcurrencyBridge()
```
- Method Detail
  - observe
```
public void observe(O observation)
```
    Specified by:
    
    observe in interface Observer<O extends Observation>
  - getSupportingTask
```
public java.lang.Runnable getSupportingTask()
```
    Specified by:
    
    getSupportingTask in interface RequiresSupportingTask
  - toString
```
public java.lang.String toString()
```
    Overrides:
    
    toString in class java.lang.Object