penicillin/blue.starry.penicillin.core.streaming.listener/StreamListener

StreamListener

interface StreamListener

A common event model interface for StreamHandler.

Functions

open suspend fun onAnyJson(json: JsonObject)

Called when any payloads are received.

open suspend fun onConnect()

Called when streaming is connected.

open suspend fun onDisconnect(cause: Throwable?)

Called when streaming is disconnected.

open suspend fun onHeartbeat()

Called when streaming sends heartbeat.

open suspend fun onLength(length: Int)

Called when streaming sends length.

open suspend fun onRawData(data: String)

Called when any data are connected.

onUnhandledJson

open suspend fun onUnhandledJson(json: JsonObject)

Called when unhandled payloads are detected.

open suspend fun onUnknownData(data: String)

Called when unhandled data are detected.

Inheritors

FilterStreamListener

LivePipelineListener

SampleStreamListener

UserStreamListener

TweetstormListener