Class: GrpcKit::Session::Stream

Inherits:
Object
  • Object
show all
Extended by:
Forwardable
Defined in:
lib/grpc_kit/session/stream.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(stream_id:) ⇒ Stream

Returns a new instance of Stream.

Parameters:

  • stream_id (Integer) 


22
23
24
25
26
27
28
29
30
31
32
33
 
# File 'lib/grpc_kit/session/stream.rb', line 22

def initialize(stream_id:)
  @stream_id = stream_id
  @end_read_stream = false
  @headers = GrpcKit::Session::Headers.new
  @pending_send_data = GrpcKit::Session::SendBuffer.new
  @pending_recv_data = GrpcKit::Session::RecvBuffer.new

  @inflight = false
  @trailer_data = {}
  @status = GrpcKit::Session::StreamStatus.new
  @draining = false
end

Instance Attribute Details

#headers ⇒ Object (readonly)

Returns the value of attribute headers.



18
19
20
 
# File 'lib/grpc_kit/session/stream.rb', line 18

def headers
  @headers
end

#inflight ⇒ Object

Returns the value of attribute inflight.



19
20
21
 
# File 'lib/grpc_kit/session/stream.rb', line 19

def inflight
  @inflight
end

#pending_recv_data ⇒ Object (readonly)

Returns the value of attribute pending_recv_data.



18
19
20
 
# File 'lib/grpc_kit/session/stream.rb', line 18

def pending_recv_data
  @pending_recv_data
end

#pending_send_data ⇒ Object (readonly)

Returns the value of attribute pending_send_data.



18
19
20
 
# File 'lib/grpc_kit/session/stream.rb', line 18

def pending_send_data
  @pending_send_data
end

#status ⇒ Object (readonly)

Returns the value of attribute status.



18
19
20
 
# File 'lib/grpc_kit/session/stream.rb', line 18

def status
  @status
end

#stream_id ⇒ Object

Returns the value of attribute stream_id.



19
20
21
 
# File 'lib/grpc_kit/session/stream.rb', line 19

def stream_id
  @stream_id
end

#trailer_data ⇒ Object (readonly)

Returns the value of attribute trailer_data.



18
19
20
 
# File 'lib/grpc_kit/session/stream.rb', line 18

def trailer_data
  @trailer_data
end

Instance Method Details

#add_header(name, value) ⇒ void

This method returns an undefined value.

Parameters:

  • name (String)
  • value (String) 


70
71
72
 
# File 'lib/grpc_kit/session/stream.rb', line 70

def add_header(name, value)
  @headers.add(name, value)
end

#drain ⇒ void

This method returns an undefined value.



44
45
46
 
# File 'lib/grpc_kit/session/stream.rb', line 44

def drain
  @draining = true
end

#end_read ⇒ Object 



39
40
41
 
# File 'lib/grpc_kit/session/stream.rb', line 39

def end_read
  @pending_recv_data.end_read
end

#end_write ⇒ Object 



35
36
37
 
# File 'lib/grpc_kit/session/stream.rb', line 35

def end_write
  @pending_send_data.end_write
end

#read_recv_data(last: false) ⇒ void

This method returns an undefined value.

Parameters:

  • last (Boolean) (defaults to: false) 


63
64
65
 
# File 'lib/grpc_kit/session/stream.rb', line 63

def read_recv_data(last: false)
  @pending_recv_data.read(last: last)
end

#write_send_data(data, last: false) ⇒ void

This method returns an undefined value.

Parameters:

  • data (String)
  • last (Boolean) (defaults to: false) 


57
58
59
 
# File 'lib/grpc_kit/session/stream.rb', line 57

def write_send_data(data, last: false)
  @pending_send_data.write(data, last: last)
end

#write_trailers_data(tarilers) ⇒ void

This method returns an undefined value.

Parameters:

  • tarilers (Hash<String,String>) 


50
51
52
 
# File 'lib/grpc_kit/session/stream.rb', line 50

def write_trailers_data(tarilers)
  @trailer_data = tarilers
end