Method: Labkit::Correlation::GRPC::ServerInterceptor#server_streamer

Defined in:
lib/labkit/correlation/grpc/server_interceptor.rb

#server_streamer(request: nil, call: nil, method: nil) ⇒ Object



29
30
31
32
33
# File 'lib/labkit/correlation/grpc/server_interceptor.rb', line 29

def server_streamer(request: nil, call: nil, method: nil)
  wrap_with_correlation_id(call) do
    yield
  end
end