Class: GrpcKit::Calls::Client::ServerStreamer

Inherits:
GrpcKit::Calls::Call show all
Defined in:
lib/grpc_kit/calls/client_server_streamer.rb

Instance Attribute Summary collapse

Attributes inherited from GrpcKit::Calls::Call

#method

Instance Method Summary collapse

Methods inherited from GrpcKit::Calls::Call

#initialize, #normal_mode, #restrict_mode

Constructor Details

This class inherits a constructor from GrpcKit::Calls::Call

Instance Attribute Details

#deadline ⇒ Object (readonly)

Returns the value of attribute deadline.



8
9
10
 
# File 'lib/grpc_kit/calls/client_server_streamer.rb', line 8

def deadline
  @deadline
end

#metadata ⇒ Object (readonly) Also known as: outgoing_metadata

Returns the value of attribute metadata.



9
10
11
 
# File 'lib/grpc_kit/calls/client_server_streamer.rb', line 9

def metadata
  @metadata
end

#method_name ⇒ Object (readonly)

Returns the value of attribute method_name.



8
9
10
 
# File 'lib/grpc_kit/calls/client_server_streamer.rb', line 8

def method_name
  @method_name
end

#service_name ⇒ Object (readonly)

Returns the value of attribute service_name.



8
9
10
 
# File 'lib/grpc_kit/calls/client_server_streamer.rb', line 8

def service_name
  @service_name
end

Instance Method Details

#each ⇒ Object 



24
25
26
 
# File 'lib/grpc_kit/calls/client_server_streamer.rb', line 24

def each
  # TODO
end

#recv(last: false) ⇒ Object 



18
19
20
21
22
 
# File 'lib/grpc_kit/calls/client_server_streamer.rb', line 18

def recv(last: false)
  raise 'No method error' if @restrict

  @stream.recv_msg(last: last)
end

#send_msg(data, timeout: nil, last: false) ⇒ Object 



12
13
14
15
16
 
# File 'lib/grpc_kit/calls/client_server_streamer.rb', line 12

def send_msg(data, timeout: nil, last: false)
  raise 'No method error' if @restrict

  @stream.send_msg(data, last: last, timeout: timeout, metadata: outgoing_metadata)
end