Class: Reactive::Observable::FromProc

Inherits:

Base

• Object
• Base
• Reactive::Observable::FromProc

Defined in:

lib/Reactive/observable/from_proc.rb

Instance Method Summary

• #initialize(&proc) ⇒ FromProc constructor

  A new instance of FromProc.

• #run(observer) ⇒ Object

Methods inherited from Base

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

Constructor Details

#initialize(&proc) ⇒ FromProc

Returns a new instance of FromProc.

# File 'lib/Reactive/observable/from_proc.rb', line 6

def initialize(&proc)
  @on_subscribe = proc
end

Instance Method Details

#run(observer) ⇒ Object

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

def run(observer)
  @on_subscribe.call(observer)
end