Class GrpcBidiResponse


public class GrpcBidiResponse extends Action<GrpcBidiResponse>
Response action for true bidirectional gRPC streaming. Expresses reactive bidi behaviour declaratively, mirroring the WebSocket HttpWebSocketResponse pattern (eager messages + first-match rule list) adapted for gRPC.

Fields:

  • headers — initial response headers (sent with the :status 200 HEADERS frame)
  • messages — EAGER server-push messages sent immediately after the initial HEADERS, regardless of inbound messages. Per-message GrpcStreamMessage.getDelay() is honoured via event-loop scheduling: each message is written after its configured delay elapses, chained sequentially so ordering is preserved. The top-level action Action.getDelay() (inherited from Action) is applied before the initial HEADERS frame is written.
  • rules — reactive rules: each inbound client message is matched against rules in order; the first rule whose matchJson matches emits its responses
  • statusName, statusMessage — final grpc-status trailer (default OK/0)
  • closeConnection — whether to close the connection after the trailing status