datalayer-grpc/com.google.android.horologist.datalayer.grpc.client/MessageClientCall

MessageClientCall

class MessageClientCall<ReqT, RespT>(channel: MessageClientChannel, methodDescriptor: MethodDescriptor<ReqT, RespT>, coroutineScope: CoroutineScope, wearDataLayerRegistry: WearDataLayerRegistry) : ClientCall<ReqT, RespT>

Constructors

MessageClientCall

constructor(channel: MessageClientChannel, methodDescriptor: MethodDescriptor<ReqT, RespT>, coroutineScope: CoroutineScope, wearDataLayerRegistry: WearDataLayerRegistry)

Functions

open override fun cancel(message: String?, cause: Throwable?)

@ExperimentalApi(value = "https://github.com/grpc/grpc-java/issues/2607")

open fun getAttributes(): Attributes

open override fun halfClose()

open fun isReady(): Boolean

open override fun request(numMessages: Int)

open override fun sendMessage(message: ReqT)

setMessageCompression

open fun setMessageCompression(p0: Boolean)

open override fun start(responseListener: ClientCall.Listener<RespT>, headers: Metadata)