tresse
A poorly thought out and stupid source+map+reduce contraption.
You source one or more pieces of data, map them a couple of times then reduce them.
By default, the whole of Tresse uses 8 work threads, it can be changed:
Tresse.max_work_thread_count # => 8
Tresse.max_work_thread_count = 10
Tresse.max_work_thread_count # => 10
use
Two sources flattened together
r =
Tresse::Group.new('test0')
.source { (0..3).to_a }
.source { (4..9).to_a }
.values # or .flatten
.sort
r #=> (0..9).to_a
Combining two sources again
r =
Tresse::Group.new('test0')
.source { (0..3).to_a }
.source { ('a'..'c').to_a }
.map { |e| e.collect { |e| e * 2 } }
.values # or .flatten
r
# => [ 0, 2, 4, 6, 'aa', 'bb', 'cc' ]
# or
# => [ 'aa', 'bb', 'cc', 0, 2, 4, 6 ]
Each can be used, the outcome of its block is discarded
t = []
# collecting on the side
r =
Tresse::Group.new('test0')
.source { (0..3).to_a }
.source { ('a'..'c').to_a }
.each { |e| t << e.collect { |e| e * 2 } }
.values
r
# => [ 0, 1, 2, 3, 'a', 'b', 'c' ]
# or
# => [ 'a', 'b', 'c', 0, 1, 2, 3 ]
t
# => [ [ 0, 2, 4, 6 ], [ 'aa', 'bb', 'cc' ] ]
# or
# => [ [ 'aa', 'bb', 'cc' ], [ 0, 2, 4, 6 ] ]
license
MIT, see LICENSE.txt