Module: Rivulet

Defined in:

lib/rivulet.rb,
lib/rivulet/deque.rb,
lib/rivulet/stream.rb,
lib/rivulet/window.rb,
lib/rivulet/version.rb,
lib/rivulet/sum_stream.rb,
lib/rivulet/sum_window.rb,
lib/rivulet/count_stream.rb,
lib/rivulet/count_window.rb,
lib/rivulet/stats_stream.rb,
lib/rivulet/stats_window.rb,
lib/rivulet/minmax_stream.rb,
lib/rivulet/minmax_window.rb,
lib/rivulet/window_builder.rb

Defined Under Namespace

Classes: CountStream, CountWindow, Deque, MinMaxStream, MinMaxWindow, StatsStream, StatsWindow, Stream, SumStream, SumWindow, Window, WindowBuilder

Constant Summary

VERSION =

"0.1.0"

Class Method Summary

• .count(source) ⇒ Object
• .minmax(source) ⇒ Object
• .stats(source) ⇒ Object
• .sum(source, &mapper) ⇒ Object

Class Method Details

.count(source) ⇒ Object

# File 'lib/rivulet.rb', line 19

def self.count(source) = CountStream.new(source)

.minmax(source) ⇒ Object

# File 'lib/rivulet.rb', line 20

def self.minmax(source) = MinMaxStream.new(source)

.stats(source) ⇒ Object

# File 'lib/rivulet.rb', line 21

def self.stats(source) = StatsStream.new(source)

.sum(source, &mapper) ⇒ Object

# File 'lib/rivulet.rb', line 18

def self.sum(source, &mapper) = SumStream.new(source, mapper: mapper || nil)