Class: MessagePack::RPC::TCPServerTransport::ServerSocket

Inherits:
MessagePack::RPC::TCPTransport::BasicSocket show all
Defined in:
lib/msgpack/rpc/transport/tcp.rb

Instance Method Summary collapse

Methods inherited from MessagePack::RPC::TCPTransport::BasicSocket

#on_read, #on_readable

Methods included from MessageReceiver

#on_message

Constructor Details

#initialize(io, server) ⇒ ServerSocket

Returns a new instance of ServerSocket.



220
221
222
223
 
# File 'lib/msgpack/rpc/transport/tcp.rb', line 220

def initialize(io, server)
  super(io)
  @server = server
end

Instance Method Details

#on_notify(method, param) ⇒ Object

MessageReceiver interface



236
237
238
 
# File 'lib/msgpack/rpc/transport/tcp.rb', line 236

def on_notify(method, param)
  @server.on_notify(method, param)
end

#on_request(msgid, method, param) ⇒ Object

MessageReceiver interface



231
232
233
 
# File 'lib/msgpack/rpc/transport/tcp.rb', line 231

def on_request(msgid, method, param)
  @server.on_request(self, msgid, method, param)
end

#on_response(msgid, error, result) ⇒ Object

MessageReceiver interface

Raises:



241
242
243
 
# File 'lib/msgpack/rpc/transport/tcp.rb', line 241

def on_response(msgid, error, result)
  raise Error.new("response message on server session")
end

#send_data(data) ⇒ Object

MessageSendable interface



226
227
228
 
# File 'lib/msgpack/rpc/transport/tcp.rb', line 226

def send_data(data)
  write data
end