Module: Streamingly

Defined in:
lib/streamingly.rb,
lib/streamingly/kv.rb,
lib/streamingly/serde.rb,
lib/streamingly/reducer.rb,
lib/streamingly/version.rb,
lib/streamingly/serde_iterable.rb

Defined Under Namespace

Modules: SerDe Classes: KV, Reducer, SerDeIterable

Constant Summary collapse

VERSION =
'0.2.3'

Class Method Summary collapse

Class Method Details

.kv(key, value) ⇒ Object



9
10
11
# File 'lib/streamingly.rb', line 9

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