EventHandler

A handler of Events.

Handles a stream of events from a Publisher.

class Object
trait Matchable
class Any

Value members

Concrete methods

def onDone(publisher: Publisher): Unit

Handles the end of a stream.

Handles the end of a stream.

Value Params
publisher

The Publisher that ended the stream.

def onEvent(event: Event): Unit

Handles an Event in the stream.

Handles an Event in the stream.

Value Params
event

The Event to handle.

def onFail(e: Throwable, publisher: Publisher): Unit

Handles an error in the stream.

Handles an error in the stream.

Value Params
e

The throwable error that occurred.

publisher

The Publisher that threw the error.

def onInit(publisher: Publisher): Unit

Handles the initialisation of a new event stream.

Handles the initialisation of a new event stream.

Value Params
publisher

The Publisher that started the stream.

Concrete fields

val id: UUID

A unique identifier for the handler.

A unique identifier for the handler.

Returns

a unique identifier