Class: GrpcKit::Session::Buffer
- Inherits:
-
Object
- Object
- GrpcKit::Session::Buffer
- Defined in:
- lib/grpc_kit/session/buffer.rb
Instance Attribute Summary collapse
-
#finish ⇒ Object
Returns the value of attribute finish.
Instance Method Summary collapse
- #end_read ⇒ Object
- #end_read? ⇒ Boolean
- #end_write ⇒ Object
- #end_write? ⇒ Boolean
-
#initialize(buffer: nil) ⇒ Buffer
constructor
A new instance of Buffer.
- #read(len = nil, last: false) ⇒ Object
- #write(data, last: false) ⇒ Object
Constructor Details
#initialize(buffer: nil) ⇒ Buffer
Returns a new instance of Buffer.
8 9 10 11 12 13 |
# File 'lib/grpc_kit/session/buffer.rb', line 8 def initialize(buffer: nil) @buffer = buffer @end_read = false @end_write = false @finish = false end |
Instance Attribute Details
#finish ⇒ Object
Returns the value of attribute finish.
6 7 8 |
# File 'lib/grpc_kit/session/buffer.rb', line 6 def finish @finish end |
Instance Method Details
#end_read ⇒ Object
52 53 54 |
# File 'lib/grpc_kit/session/buffer.rb', line 52 def end_read @end_read = true end |
#end_read? ⇒ Boolean
44 45 46 |
# File 'lib/grpc_kit/session/buffer.rb', line 44 def end_read? @end_read end |
#end_write ⇒ Object
56 57 58 |
# File 'lib/grpc_kit/session/buffer.rb', line 56 def end_write @end_write = true end |
#end_write? ⇒ Boolean
48 49 50 |
# File 'lib/grpc_kit/session/buffer.rb', line 48 def end_write? @end_write end |
#read(len = nil, last: false) ⇒ Object
29 30 31 32 33 34 35 36 37 38 39 40 41 42 |
# File 'lib/grpc_kit/session/buffer.rb', line 29 def read(len = nil, last: false) if @buffer.nil? || @buffer.empty? return '' end end_read if last # TODO: more efficient code if len @buffer.slice!(0...len) else @buffer.slice!(0..-1) end end |
#write(data, last: false) ⇒ Object
15 16 17 18 19 20 21 22 23 24 25 26 27 |
# File 'lib/grpc_kit/session/buffer.rb', line 15 def write(data, last: false) return 0 if data.empty? end_write if last if @buffer @buffer << data else @buffer = data.dup end data.bytesize end |