LivePipelineListener

An event model interface for LivePipelineHandler.

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.

open suspend fun onUnhandledJson(json: JsonObject)

Called when unhandled payloads are detected.

open suspend fun onUnknownData(data: String)

Called when unhandled data are detected.

open suspend fun onUpdateLikeCount(id: Long, count: Int)

Called when a status like count increments.

open suspend fun onUpdateReplyCount(id: Long, count: Int)

Called when a status reply count increments.

open suspend fun onUpdateRetweetCount(id: Long, count: Int)

Called when a status retweet count increments.