ControllerEventStreamExtensions extension

Extension methods for filtering controller event streams.

on

Properties

configUpdates → Stream<ConfigUpdateEvent>

Available on Stream<ControllerEvent>, provided by the ControllerEventStreamExtensions extension

Filter to config update events only.
no setter
coordinationSendHealth → Stream<CoordinationSendHealthEvent>

Available on Stream<ControllerEvent>, provided by the ControllerEventStreamExtensions extension

Filter to outbound-coordination health events only.
no setter
nodeJoined → Stream<NodeJoinedEvent>

Available on Stream<ControllerEvent>, provided by the ControllerEventStreamExtensions extension

Filter to node joined events only.
no setter
nodeJoinRejected → Stream<NodeJoinRejectedEvent>

Available on Stream<ControllerEvent>, provided by the ControllerEventStreamExtensions extension

Filter to node join rejection events only (coordinator side).
no setter
nodeLeft → Stream<NodeLeftEvent>

Available on Stream<ControllerEvent>, provided by the ControllerEventStreamExtensions extension

Filter to node left events only.
no setter
phaseChanges → Stream<PhaseChangedEvent>

Available on Stream<ControllerEvent>, provided by the ControllerEventStreamExtensions extension

Filter to phase change events only.
no setter
sessionEnded → Stream<SessionEndedEvent>

Available on Stream<ControllerEvent>, provided by the ControllerEventStreamExtensions extension

Filter to session-ended events only.
no setter
sessionRejoined → Stream<SessionRejoinedEvent>

Available on Stream<ControllerEvent>, provided by the ControllerEventStreamExtensions extension

Filter to session rejoined events only.
no setter
streamCreate → Stream<StreamCreateEvent>

Available on Stream<ControllerEvent>, provided by the ControllerEventStreamExtensions extension

Filter to stream create events only.
no setter
streamDestroy → Stream<StreamDestroyEvent>

Available on Stream<ControllerEvent>, provided by the ControllerEventStreamExtensions extension

Filter to stream destroy events only.
no setter
streamFlush → Stream<StreamFlushEvent>

Available on Stream<ControllerEvent>, provided by the ControllerEventStreamExtensions extension

Filter to stream flush events only.
no setter
streamLifecycle → Stream<StreamLifecycleEvent>

Available on Stream<ControllerEvent>, provided by the ControllerEventStreamExtensions extension

Filter to all stream lifecycle events.
no setter
streamPause → Stream<StreamPauseEvent>

Available on Stream<ControllerEvent>, provided by the ControllerEventStreamExtensions extension

Filter to stream pause events only.
no setter
streamReady → Stream<StreamReadyEvent>

Available on Stream<ControllerEvent>, provided by the ControllerEventStreamExtensions extension

Filter to stream ready events only.
no setter
streamReceiveHealth → Stream<StreamReceiveHealthEvent>

Available on Stream<ControllerEvent>, provided by the ControllerEventStreamExtensions extension

Filter to stream receive-health events only.
no setter
streamResume → Stream<StreamResumeEvent>

Available on Stream<ControllerEvent>, provided by the ControllerEventStreamExtensions extension

Filter to stream resume events only.
no setter
streamStart → Stream<StreamStartEvent>

Available on Stream<ControllerEvent>, provided by the ControllerEventStreamExtensions extension

Filter to stream start events only.
no setter
streamStop → Stream<StreamStopEvent>

Available on Stream<ControllerEvent>, provided by the ControllerEventStreamExtensions extension

Filter to stream stop events only.
no setter
userCoordinationMessages → Stream<UserCoordinationEvent>

Available on Stream<ControllerEvent>, provided by the ControllerEventStreamExtensions extension

Filter to coordinator user messages only.
no setter
userMessages → Stream<UserMessageEvent>

Available on Stream<ControllerEvent>, provided by the ControllerEventStreamExtensions extension

Filter to all user message events.
no setter
userParticipantMessages → Stream<UserParticipantEvent>

Available on Stream<ControllerEvent>, provided by the ControllerEventStreamExtensions extension

Filter to participant user messages only.
no setter