GoldenGateConnectionManager / com.fitbit.goldengate.node / StackEventHandler

StackEventHandler

class StackEventHandler

Receives stack events and dispatches them to the right handler. For now this only supports gattlink buffer events.

Parameters

eventStream - The stream emitting stack events

gattConnection - The connection on which to operate

linkController - The link controller instance (default)

votingEnabled - Determines whether we enable voting for fast/slow mode

Constructors

<init>

StackEventHandler(eventStream: Observable<StackEvent>, gattConnection: GattConnection, votingEnabled: Boolean = true, linkControllerProvider: (GattConnection) -> LinkController = { LinkControllerProvider.INSTANCE.getLinkController(it) })

Receives stack events and dispatches them to the right handler. For now this only supports gattlink buffer events.

Properties

eventStream

val eventStream: Observable<StackEvent>

The stream emitting stack events

gattConnection

val gattConnection: GattConnection

The connection on which to operate

linkControllerProvider

val linkControllerProvider: (GattConnection) -> LinkController

Functions

dispatchEvents

fun dispatchEvents(): Completable