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