Class: Reactive::Observable::Push

Inherits:

Composite

• Object
• Base
• Composite
• Reactive::Observable::Push

Defined in:

lib/Reactive/observable/push.rb

Defined Under Namespace

Classes: Observer

Instance Method Summary

• #initial_subscriptions ⇒ Object

  def initialize(o1, o2) @o1, @o2 = o1, o2 end.

• #observer_args(observer, parent) ⇒ Object

Methods inherited from Composite

#fill_disposable_parent, #run

Methods inherited from Base

add_attributes, #first, #grep, #initialize, #map, #maybe_scheduler, #merge, observer_on_next, #push, #scheduler, #skip, #subscribe, #subscribe_observer

Constructor Details

This class inherits a constructor from Reactive::Observable::Base

Instance Method Details

#initial_subscriptions ⇒ Object

def initialize(o1, o2)

@o1, @o2 = o1, o2

end

# File 'lib/Reactive/observable/push.rb', line 10

def initial_subscriptions
  [@o1]
end

#observer_args(observer, parent) ⇒ Object

# File 'lib/Reactive/observable/push.rb', line 14

def observer_args(observer, parent)
    [observer, parent, @o2]
end