Class: Reactive::Observable::Skip::Observer

Inherits:
Reactive::ObserverWrapper show all
Defined in:
lib/Reactive/observable/skip.rb

Instance Attribute Summary

Attributes inherited from Reactive::ObserverWrapper

#parent, #target

Instance Method Summary collapse

Methods inherited from Reactive::ObserverWrapper

#active?, #attributes, #on_complete, #unwrap, #unwrap_parent, #wrap_with_parent

Constructor Details

#initialize(*args) ⇒ Observer

Returns a new instance of Observer.



8
9
10
11
 
# File 'lib/Reactive/observable/skip.rb', line 8

def initialize(*args)
  @skipped = 0
  super
end

Instance Method Details

#on_next(value) ⇒ Object 



13
14
15
16
17
18
19
 
# File 'lib/Reactive/observable/skip.rb', line 13

def on_next(value)
  if @skipped == @count
    @target.on_next(value)
  else
    @skipped += 1
  end
end