Class: Thrift::BufferedTransport
- Inherits:
-
BaseTransport
- Object
- BaseTransport
- Thrift::BufferedTransport
- Defined in:
- lib/thrift/transport/buffered_transport.rb
Constant Summary collapse
- DEFAULT_BUFFER =
4096
Instance Method Summary collapse
- #close ⇒ Object
- #flush ⇒ Object
-
#initialize(transport) ⇒ BufferedTransport
constructor
A new instance of BufferedTransport.
- #open ⇒ Object
- #open? ⇒ Boolean
- #read(sz) ⇒ Object
- #write(buf) ⇒ Object
Methods inherited from BaseTransport
Constructor Details
#initialize(transport) ⇒ BufferedTransport
Returns a new instance of BufferedTransport.
25 26 27 28 29 30 |
# File 'lib/thrift/transport/buffered_transport.rb', line 25 def initialize(transport) @transport = transport @wbuf = '' @rbuf = '' @index = 0 end |
Instance Method Details
#close ⇒ Object
40 41 42 43 |
# File 'lib/thrift/transport/buffered_transport.rb', line 40 def close flush @transport.close end |
#flush ⇒ Object
62 63 64 65 66 67 68 69 |
# File 'lib/thrift/transport/buffered_transport.rb', line 62 def flush if @wbuf != '' @transport.write(@wbuf) @wbuf = '' end @transport.flush end |
#open ⇒ Object
36 37 38 |
# File 'lib/thrift/transport/buffered_transport.rb', line 36 def open @transport.open end |
#open? ⇒ Boolean
32 33 34 |
# File 'lib/thrift/transport/buffered_transport.rb', line 32 def open? return @transport.open? end |
#read(sz) ⇒ Object
45 46 47 48 49 50 51 52 53 54 55 56 |
# File 'lib/thrift/transport/buffered_transport.rb', line 45 def read(sz) @index += sz ret = @rbuf.slice(@index - sz, sz) || '' if ret.length == 0 @rbuf = @transport.read([sz, DEFAULT_BUFFER].max) @index = sz ret = @rbuf.slice(0, sz) || '' end ret end |
#write(buf) ⇒ Object
58 59 60 |
# File 'lib/thrift/transport/buffered_transport.rb', line 58 def write(buf) @wbuf << buf end |