class Frappuccino::Scan

Public Class Methods

new(source, zero, &blk) click to toggle source
# File lib/frappuccino/stream/scan.rb, line 3
def initialize(source, zero, &blk)
  @last = zero
  @block = blk

  source.add_observer(self)
end

Public Instance Methods

update(value) click to toggle source
# File lib/frappuccino/stream/scan.rb, line 10
def update(value)
  @last = @block.call(@last, value)
  occur(@last)
end