Module: DStream

Defined in:
lib/d-stream.rb,
lib/d-stream/version.rb

Defined Under Namespace

Classes: Abstract, Buffer, Burst, Compose, Flatten2, Scan, Simple1, SimpleB, Trickle, WithNext, Zip

Constant Summary collapse

VERSION = 
'0.0.1'.freeze

Class Method Summary collapse

Class Method Details

.apply(s, *procs) ⇒ Object 



255
256
257
 
# File 'lib/d-stream.rb', line 255

def self.apply(s, *procs)
  compose(*procs).apply(s)
end

.buffer(size) ⇒ Object 



215
216
217
 
# File 'lib/d-stream.rb', line 215

def self.buffer(size)
  Buffer.new(size)
end

.burst(rate, size) ⇒ Object 



211
212
213
 
# File 'lib/d-stream.rb', line 211

def self.burst(rate, size)
  Burst.new(rate, size)
end

.chunk_by ⇒ Object 



243
244
245
 
# File 'lib/d-stream.rb', line 243

def self.chunk_by
  # …
end

.compose(*procs) ⇒ Object 



251
252
253
 
# File 'lib/d-stream.rb', line 251

def self.compose(*procs)
  Compose.new(procs)
end

.flatten2 ⇒ Object 



235
236
237
 
# File 'lib/d-stream.rb', line 235

def self.flatten2
  Flatten2.new
end

.map(&block) ⇒ Object 



203
204
205
 
# File 'lib/d-stream.rb', line 203

def self.map(&block)
  SimpleB.new(:map, &block)
end

.reduce(&block) ⇒ Object 



227
228
229
 
# File 'lib/d-stream.rb', line 227

def self.reduce(&block)
  SimpleB.new(:reduce, &block)
end

.scan(init, &block) ⇒ Object 



231
232
233
 
# File 'lib/d-stream.rb', line 231

def self.scan(init, &block)
  Scan.new(init, &block)
end

.select(&block) ⇒ Object 



223
224
225
 
# File 'lib/d-stream.rb', line 223

def self.select(&block)
  SimpleB.new(:select, &block)
end

.take(n) ⇒ Object 



239
240
241
 
# File 'lib/d-stream.rb', line 239

def self.take(n)
  Simple1.new(:take, n)
end

.trickle(rate) ⇒ Object 



207
208
209
 
# File 'lib/d-stream.rb', line 207

def self.trickle(rate)
  Trickle.new(rate)
end

.with_next ⇒ Object 



219
220
221
 
# File 'lib/d-stream.rb', line 219

def self.with_next
  WithNext.new
end

.zip(other) ⇒ Object 



247
248
249
 
# File 'lib/d-stream.rb', line 247

def self.zip(other)
  Zip.new(other)
end