proter-root/com.workflowfm.proter.events/PoolEventHandler

PoolEventHandler

trait PoolEventHandler extends EventHandler

An EventHandler for a pool of Coordinators.

class Object
trait Matchable
class Any

Value members

Concrete methods

override
def onDone(publisher: Publisher): Unit

Handles the end of a stream.

Handles the end of a stream.

Closes the event stream by removing the publisher from publishers.

Definition Classes
override
def onFail(e: Throwable, publisher: Publisher): Unit

Handles an error in the stream.

Handles an error in the stream.

Closes the event stream by removing the publisher from publishers.

Definition Classes
override
def onInit(publisher: Publisher): Unit

Handles the initialisation of a new event stream.

Handles the initialisation of a new event stream.

Adds the publisher to publishers.

Definition Classes

Inherited methods

def onEvent(event: Event): Unit

Handles an Event in the stream.

Handles an Event in the stream.

Value Params
event

The Event to handle.

Inherited from
EventHandler

Concrete fields

val publishers: HashSet[Publisher]

The set of Publishers we have subscribed to.

The set of Publishers we have subscribed to.

Inherited fields

val id: UUID

A unique identifier for the handler.

A unique identifier for the handler.

Returns

a unique identifier

Inherited from
EventHandler