class Transit::Unmarshaler::MessagePack

@api private

Public Class Methods

new(io, opts) click to toggle source
# File lib/transit/unmarshaler/cruby/messagepack.rb, line 24
def initialize(io, opts)
  @decoder = Transit::Decoder.new(opts)
  @unpacker = ::MessagePack::Unpacker.new(io)
end

Public Instance Methods

read() { |decode| ... } click to toggle source

@see Reader#read

# File lib/transit/unmarshaler/cruby/messagepack.rb, line 30
def read
  if block_given?
    @unpacker.each {|v| yield @decoder.decode(v)}
  else
    @decoder.decode(@unpacker.read)
  end
end