コンテンツにスキップ
日本語

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.

readonly metadata: Readonly<Record<string, string>>

Defined in: src/io/broker/GrpcServerActor.ts:64


readonly method: string

Defined in: src/io/broker/GrpcServerActor.ts:63

onData(target): void

Defined in: src/io/broker/GrpcServerActor.ts:66

Subscribe an actor to receive every inbound chunk + the end signal.

ActorRef<GrpcRequestStreamInbound>

void


respond(response): void

Defined in: src/io/broker/GrpcServerActor.ts:68

Reply with success (status OK). Only the first call takes effect.

unknown

void


respondError(message, code?): void

Defined in: src/io/broker/GrpcServerActor.ts:70

Reply with an error. code defaults to 13 (INTERNAL).

string

number

void