module Bones::RPC::Adapter::Msgpack
Constants
- Unpacker
- VERSION
Public Instance Methods
pack(message, buffer="")
click to toggle source
# File lib/bones/rpc/adapter/msgpack.rb, line 12 def pack(message, buffer="") buffer << ::MessagePack.pack(message) end
parser(data)
click to toggle source
# File lib/bones/rpc/adapter/msgpack.rb, line 33 def parser(data) Adapter::Parser.new(self, data) end
read(unpacker)
click to toggle source
# File lib/bones/rpc/adapter/msgpack.rb, line 25 def read(unpacker) (unpacker.adapter_unpacker ||= ::MessagePack::Unpacker.new(unpacker.buffer)).read end
unpack(buffer)
click to toggle source
# File lib/bones/rpc/adapter/msgpack.rb, line 16 def unpack(buffer) ::MessagePack.unpack(buffer) end
unpack_stream(stream)
click to toggle source
# File lib/bones/rpc/adapter/msgpack.rb, line 20 def unpack_stream(stream) buffer = StringIO.new(stream) ::MessagePack::Unpacker.new(buffer).read end
unpacker(data)
click to toggle source
# File lib/bones/rpc/adapter/msgpack.rb, line 29 def unpacker(data) Unpacker.new(StringIO.new(data)) end
unpacker_pos(parser)
click to toggle source
# File lib/bones/rpc/adapter/msgpack.rb, line 41 def unpacker_pos(parser) parser.unpacker.buffer.pos end
unpacker_seek(parser, n)
click to toggle source
# File lib/bones/rpc/adapter/msgpack.rb, line 45 def unpacker_seek(parser, n) parser.unpacker.buffer.seek(n) return n end