StreamObserverHelper

class StreamObserverHelper<T> : StreamObserver<T>

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

the response element type

Constructors

constructor()

open override fun onCompleted()

fun onCompleted(block: () -> Unit)

Registers a callback invoked when the stream completes successfully.

Registers a callback invoked when the stream encounters an error.

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.