tuweni / org.apache.tuweni.scuttlebutt.rpc.mux / ScuttlebuttStreamHandler

ScuttlebuttStreamHandler

interface ScuttlebuttStreamHandler (source)

Handles incoming items from a result stream

Functions

onMessage

Handles a new message from the result stream.

abstract fun onMessage(message: RPCResponse!): Unit

onStreamEnd

Invoked when the stream has been closed.

abstract fun onStreamEnd(): Unit

onStreamError

Invoked when there is an error in the stream.

abstract fun onStreamError(ex: Exception!): Unit