Class: MessagePack::RPC::TCPTransport::BasicSocket

Inherits:
Cool.io::TCPSocket
  • Object
show all
Includes:
MessageReceiver
Defined in:
lib/msgpack/rpc/transport/tcp.rb

Instance Method Summary collapse

Methods included from MessageReceiver

#on_message

Constructor Details

#initialize(io) ⇒ BasicSocket

Returns a new instance of BasicSocket.



35
36
37
38
 
# File 'lib/msgpack/rpc/transport/tcp.rb', line 35

def initialize(io)
	super(io)
	@pac = MessagePack::Unpacker.new
end

Instance Method Details

#on_read(data) ⇒ Object

from Cool.io::TCPSocket



50
51
52
53
54
 
# File 'lib/msgpack/rpc/transport/tcp.rb', line 50

def on_read(data)
	@pac.feed_each(data) {|obj|
		on_message(obj)
	}
end

#on_readable ⇒ Object

from Cool.io::TCPSocket



41
42
43
44
45
46
47
 
# File 'lib/msgpack/rpc/transport/tcp.rb', line 41

def on_readable
	super
rescue
	# FIXME send Connection Close message
	# FIXME log
	close
end