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

.kv(key, value) ⇒ Object

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