MessagePack::RPC::TCPClientTransport::ClientSocket

     # File lib/msgpack/rpc/transport/tcp.rb, line 134
134:                 def initialize(io, transport, session)
135:                         super(io)
136:                         @t = transport
137:                         @s = session
138:                 end

     # File lib/msgpack/rpc/transport/tcp.rb, line 180
180:                 def on_close
181:                         return unless @t
182:                         @t.on_close(self)
183:                         @t = nil
184:                         @s = nil
185:                 rescue
186:                         nil
187:                 end

     # File lib/msgpack/rpc/transport/tcp.rb, line 166
166:                 def on_connect
167:                         return unless @t
168:                         @t.on_connect(self)
169:                 end

     # File lib/msgpack/rpc/transport/tcp.rb, line 172
172:                 def on_connect_failed
173:                         return unless @t
174:                         @t.on_connect_failed(self)
175:                 rescue
176:                         nil
177:                 end

     # File lib/msgpack/rpc/transport/tcp.rb, line 156
156:                 def on_notify(method, param)
157:                         raise Error.new("notify message on client session")
158:                 end

     # File lib/msgpack/rpc/transport/tcp.rb, line 151
151:                 def on_request(msgid, method, param)
152:                         raise Error.new("request message on client session")
153:                 end

     # File lib/msgpack/rpc/transport/tcp.rb, line 161
161:                 def on_response(msgid, error, result)
162:                         @s.on_response(self, msgid, error, result)
163:                 end

     # File lib/msgpack/rpc/transport/tcp.rb, line 141
141:                 def send_data(data)
142:                         write data
143:                 end

     # File lib/msgpack/rpc/transport/tcp.rb, line 146
146:                 def send_pending(data)
147:                         write data
148:                 end