GrpcClientStreamCall
此内容尚不支持你的语言。
Defined in: src/io/broker/GrpcServerActor.ts:62
Inbound client-stream call — handler consumes chunks via onData
and answers once via respond / respondError.
There is no request: a client-streaming RPC has no single request
message, which is exactly what distinguishes it from a unary call.
The reply half is a unary reply, which is what distinguishes it from
a bidi call.
Properties
Section titled “Properties”metadata
Section titled “metadata”
readonlymetadata:Readonly<Record<string,string>>
Defined in: src/io/broker/GrpcServerActor.ts:64
method
Section titled “method”
readonlymethod:string
Defined in: src/io/broker/GrpcServerActor.ts:63
Methods
Section titled “Methods”onData()
Section titled “onData()”onData(
target):void
Defined in: src/io/broker/GrpcServerActor.ts:66
Subscribe an actor to receive every inbound chunk + the end signal.
Parameters
Section titled “Parameters”target
Section titled “target”ActorRef<GrpcRequestStreamInbound>
Returns
Section titled “Returns”void
respond()
Section titled “respond()”respond(
response):void
Defined in: src/io/broker/GrpcServerActor.ts:68
Reply with success (status OK). Only the first call takes effect.
Parameters
Section titled “Parameters”response
Section titled “response”unknown
Returns
Section titled “Returns”void
respondError()
Section titled “respondError()”respondError(
message,code?):void
Defined in: src/io/broker/GrpcServerActor.ts:70
Reply with an error. code defaults to 13 (INTERNAL).
Parameters
Section titled “Parameters”message
Section titled “message”string
number
Returns
Section titled “Returns”void
