Module: Baykit::BayServer::Agent::Multiplexer::Transporter
- Includes:
- Util::Reusable
- Included in:
- PlainTransporter
- Defined in:
- lib/baykit/bayserver/agent/multiplexer/transporter.rb
Overview
interface
Instance Method Summary collapse
- #check_timeout(rd, duretion_sec) ⇒ Object
- #get_read_buffer_size ⇒ Object
- #init ⇒ Object
- #on_closed(rd) ⇒ Object
- #on_connected(rd) ⇒ Object
- #on_error(rd, e) ⇒ Object
- #on_read(rd, data, adr) ⇒ Object
- #print_usage(indent) ⇒ Object
- #req_close(rd) ⇒ Object
- #req_connect(rd, adr) ⇒ Object
- #req_read(rd) ⇒ Object
- #req_write(rd, buf, adr, tag, &lis) ⇒ Object
Instance Method Details
#check_timeout(rd, duretion_sec) ⇒ Object
46 47 48 |
# File 'lib/baykit/bayserver/agent/multiplexer/transporter.rb', line 46 def check_timeout(rd, duretion_sec) raise NotImplementedError.new end |
#get_read_buffer_size ⇒ Object
50 51 52 |
# File 'lib/baykit/bayserver/agent/multiplexer/transporter.rb', line 50 def get_read_buffer_size raise NotImplementedError.new end |
#init ⇒ Object
10 11 12 |
# File 'lib/baykit/bayserver/agent/multiplexer/transporter.rb', line 10 def init() raise NotImplementedError.new end |
#on_closed(rd) ⇒ Object
26 27 28 |
# File 'lib/baykit/bayserver/agent/multiplexer/transporter.rb', line 26 def on_closed(rd) raise NotImplementedError.new end |
#on_connected(rd) ⇒ Object
14 15 16 |
# File 'lib/baykit/bayserver/agent/multiplexer/transporter.rb', line 14 def on_connected(rd) raise NotImplementedError.new end |
#on_error(rd, e) ⇒ Object
22 23 24 |
# File 'lib/baykit/bayserver/agent/multiplexer/transporter.rb', line 22 def on_error(rd, e) raise NotImplementedError.new end |
#on_read(rd, data, adr) ⇒ Object
18 19 20 |
# File 'lib/baykit/bayserver/agent/multiplexer/transporter.rb', line 18 def on_read(rd, data, adr) raise NotImplementedError.new end |
#print_usage(indent) ⇒ Object
54 55 56 |
# File 'lib/baykit/bayserver/agent/multiplexer/transporter.rb', line 54 def print_usage(indent) raise NotImplementedError.new end |
#req_close(rd) ⇒ Object
42 43 44 |
# File 'lib/baykit/bayserver/agent/multiplexer/transporter.rb', line 42 def req_close(rd) raise NotImplementedError.new end |
#req_connect(rd, adr) ⇒ Object
30 31 32 |
# File 'lib/baykit/bayserver/agent/multiplexer/transporter.rb', line 30 def req_connect(rd, adr) raise NotImplementedError.new end |
#req_read(rd) ⇒ Object
34 35 36 |
# File 'lib/baykit/bayserver/agent/multiplexer/transporter.rb', line 34 def req_read(rd) raise NotImplementedError.new end |
#req_write(rd, buf, adr, tag, &lis) ⇒ Object
38 39 40 |
# File 'lib/baykit/bayserver/agent/multiplexer/transporter.rb', line 38 def req_write(rd, buf, adr, tag, &lis) raise NotImplementedError.new end |