View Source GRPC.Server.Stream (grpc v0.9.0)

A struct as an argument that servers get in rpc function definitions and use to handle headers, send streaming replies.

Notice that you MUST use new stream returned by GRPC.Server as an argument to invoke next functions defined by GRPC.Server.

Fields

  • :server - user defined gRPC server module
  • :adapter - a server adapter module, like GRPC.Server.Adapters.Cowboy
  • request_mod - the request module, or nil for untyped protocols
  • response_mod - the response module, or nil for untyped protocols
  • :codec - the codec
  • :payload - the payload needed by the adapter
  • :local - local data initialized by user

Summary

Types

@type t() :: %GRPC.Server.Stream{
  __interface__: map(),
  adapter: atom(),
  codec: atom(),
  compressor: module() | nil,
  endpoint: atom(),
  grpc_type: atom(),
  http_method: GRPC.Server.Router.http_method(),
  http_transcode: boolean(),
  local: any(),
  method_name: String.t(),
  payload: any(),
  request_id: String.t() | nil,
  request_mod: atom(),
  response_mod: atom(),
  rpc: tuple(),
  server: atom(),
  service_name: String.t()
}

Functions

Link to this function

send_reply(stream, reply, opts)

View Source