View Source GRPC.Server.Interceptor behaviour (grpc v0.9.0)

Interceptor on server side. See GRPC.Endpoint.

Summary

next()

options()

rpc_return()

init(options)

@type next() :: (GRPC.Server.rpc_req(), GRPC.Server.Stream.t() -> rpc_return())

@type options() :: any()

@type rpc_return() ::
  {:ok, GRPC.Server.Stream.t(), struct()}
  | {:ok, GRPC.Server.Stream.t()}
  | {:error, GRPC.RPCError.t()}

@callback call(GRPC.Server.rpc_req(), stream :: GRPC.Server.Stream.t(), next(), options()) ::
  rpc_return()

@callback init(options()) :: options()