Parent

Rev::TCPSocket

Included Modules

  • MessageReceiver

Class Index [+]

Quicksearch

MessagePack::RPC::TCPTransport::BasicSocket

Public Class Methods

new(io) click to toggle source 
    # File lib/msgpack/rpc/transport/tcp.rb, line 35
35:                 def initialize(io)
36:                         super(io)
37:                         @pac = MessagePack::Unpacker.new
38:                 end

Public Instance Methods

on_read(data) click to toggle source

from Rev::TCPSocket 

    # File lib/msgpack/rpc/transport/tcp.rb, line 50
50:                 def on_read(data)
51:                         @pac.feed_each(data) {|obj|
52:                                 on_message(obj)
53:                         }
54:                 end
on_readable() click to toggle source

from Rev::TCPSocket 

    # File lib/msgpack/rpc/transport/tcp.rb, line 41
41:                 def on_readable
42:                         super
43:                 rescue
44:                         # FIXME send Connection Close message
45:                         # FIXME log
46:                         close
47:                 end

Disabled; run with --debug to generate this.

[Validate]

Generated with the Darkfish Rdoc Generator 1.1.6.