Method: GRPC::ActiveCall#remote_send

Defined in:
src/ruby/lib/grpc/generic/active_call.rb

#remote_send(req, marshalled = false) ⇒ Object

remote_send sends a request to the remote endpoint.

It blocks until the remote endpoint accepts the message.

marshalled.

Parameters:

  • the object to send or it’s marshal form.

  • (defaults to: false)

    indicates if the object is already



199
200
201
202
203
204
 
# File 'src/ruby/lib/grpc/generic/active_call.rb', line 199

def remote_send(req, marshalled = false)
  send_initial_metadata
  GRPC.logger.debug("sending #{req}, marshalled? #{marshalled}")
  payload = marshalled ? req : @marshal.call(req)
  @call.run_batch(SEND_MESSAGE => payload)
end