class Spark::Serializer::Base

@abstract Parent for all serializers

Public Instance Methods

==(other) click to toggle source
# File lib/spark/serializer/base.rb, line 28
def ==(other)
  self.to_s == other.to_s
end
batched?() click to toggle source
# File lib/spark/serializer/base.rb, line 32
def batched?
  false
end
check_each(data) click to toggle source
# File lib/spark/serializer/base.rb, line 39
def check_each(data)
  unless data.respond_to?(:each)
    error('Data must be iterable.')
  end
end
error(message) click to toggle source
# File lib/spark/serializer/base.rb, line 45
def error(message)
  raise Spark::SerializeError, message
end
inspect() click to toggle source
# File lib/spark/serializer/base.rb, line 57
def inspect
  %{#<Spark::Serializer:0x#{object_id}  "#{self}">}
end
load_from_file(file, *args) { |item| ... } click to toggle source
# File lib/spark/serializer/base.rb, line 17
def load_from_file(file, *args)
  return to_enum(__callee__, file, *args) unless block_given?

  load_from_io(file, *args).each do |item|
    yield item
  end

  file.close
  file.unlink
end
load_from_io(io) { |load(read)| ... } click to toggle source
# File lib/spark/serializer/base.rb, line 6
def load_from_io(io)
  return to_enum(__callee__, io) unless block_given?

  loop do
    size = io.read_int_or_eof
    break if size == Spark::Constant::DATA_EOF

    yield load(io.read(size))
  end
end
name() click to toggle source
# File lib/spark/serializer/base.rb, line 49
def name
  self.class.name.split('::').last
end
to_s() click to toggle source
# File lib/spark/serializer/base.rb, line 53
def to_s
  name
end
unbatch!() click to toggle source
# File lib/spark/serializer/base.rb, line 36
def unbatch!
end