Class: MessagePack::RPC::UNIXServerTransport::ServerSocket
- Inherits:
-
MessagePack::RPC::UNIXTransport::BasicSocket
- Object
- Rev::UNIXSocket
- MessagePack::RPC::UNIXTransport::BasicSocket
- MessagePack::RPC::UNIXServerTransport::ServerSocket
- Defined in:
- lib/msgpack/rpc/transport/unix.rb
Instance Method Summary collapse
-
#initialize(io, server) ⇒ ServerSocket
constructor
A new instance of ServerSocket.
-
#on_notify(method, param) ⇒ Object
MessageReceiver interface.
-
#on_request(msgid, method, param) ⇒ Object
MessageReceiver interface.
-
#on_response(msgid, error, result) ⇒ Object
MessageReceiver interface.
-
#send_data(data) ⇒ Object
MessageSendable interface.
Methods inherited from MessagePack::RPC::UNIXTransport::BasicSocket
Methods included from MessageReceiver
Constructor Details
#initialize(io, server) ⇒ ServerSocket
Returns a new instance of ServerSocket.
144 145 146 147 |
# File 'lib/msgpack/rpc/transport/unix.rb', line 144 def initialize(io, server) super(io) @server = server end |
Instance Method Details
#on_notify(method, param) ⇒ Object
MessageReceiver interface
160 161 162 |
# File 'lib/msgpack/rpc/transport/unix.rb', line 160 def on_notify(method, param) @server.on_notify(method, param) end |
#on_request(msgid, method, param) ⇒ Object
MessageReceiver interface
155 156 157 |
# File 'lib/msgpack/rpc/transport/unix.rb', line 155 def on_request(msgid, method, param) @server.on_request(self, msgid, method, param) end |
#on_response(msgid, error, result) ⇒ Object
MessageReceiver interface
165 166 167 |
# File 'lib/msgpack/rpc/transport/unix.rb', line 165 def on_response(msgid, error, result) raise Error.new("response message on server session") end |
#send_data(data) ⇒ Object
MessageSendable interface
150 151 152 |
# File 'lib/msgpack/rpc/transport/unix.rb', line 150 def send_data(data) write data end |