StreamObserverHelper

class StreamObserverHelper<T> : StreamObserver<T>

A DSL-friendly StreamObserver implementation that delegates to user-supplied lambda callbacks.

Each callback is single-assignment; registering one twice throws IllegalStateException. An unregistered callback does nothing.

the response element type

Constructors

constructor()

open override fun onCompleted()

fun onCompleted(block: () -> Unit)

Registers a callback invoked when the stream completes successfully. Can be called only once.

Registers a callback invoked when the stream encounters an error. Can be called only once.

open override fun onError(t: Throwable)

open override fun onNext(response: T)

fun onNext(block: (T) -> Unit)

Registers a callback invoked for each response element. Can be called only once.