penicillin/blue.starry.penicillin.core.streaming.handler/LivePipelineHandler

LivePipelineHandler

class LivePipelineHandler(val client: ApiClient, val listener: LivePipelineListener) : StreamHandler<LivePipelineListener>

Default LivePipeline StreamHandler. Accepts listener of LivePipelineListener.

Constructors

LivePipelineHandler

fun LivePipelineHandler(client: ApiClient, listener: LivePipelineListener)

Functions

open suspend override fun handle(json: JsonObject)

Handles streaming payload JSON.

Properties

open override val client: ApiClient

Current ApiClient.

open override val listener: LivePipelineListener

StreamListener.