Subscriber

class Subscriber(channel: SendChannel<Request.Event>) : HttpResponse.BodySubscriber<Unit>

Constructors

fun Subscriber(channel: SendChannel<Request.Event>)

open override fun onComplete()

open override fun onError(throwable: Throwable)

open override fun onNext(item: MutableList<ByteBuffer>)

open override fun onSubscribe(subscription: Flow.Subscription)