Contents

require "streamingly/version"
require "streamingly/reducer"
require "streamingly/kv"
require "streamingly/serde"
require "streamingly/serde_iterable"

module Streamingly

  def self.kv(key, value)
    KV.new(key, value).to_s
  end

end

Version data entries

11 entries across 11 versions & 1 rubygems

Version	Path
streamingly-0.2.7	lib/streamingly.rb
streamingly-0.2.6	lib/streamingly.rb
streamingly-0.2.4	lib/streamingly.rb
streamingly-0.2.3	lib/streamingly.rb
streamingly-0.2.2	lib/streamingly.rb
streamingly-0.2.0	lib/streamingly.rb
streamingly-0.1.0	lib/streamingly.rb
streamingly-0.0.8	lib/streamingly.rb
streamingly-0.0.5	lib/streamingly.rb
streamingly-0.0.4	lib/streamingly.rb
streamingly-0.0.3.pre	lib/streamingly.rb