Class: Reacto::Subscriptions::FlatMapSubscription

Inherits:
CompositeSubscription show all
Defined in:
lib/reacto/subscriptions/flat_map_subscription.rb

Instance Method Summary collapse

Methods inherited from CompositeSubscription

#add, #add_resource, #after_on_value, #closed?, #on_close, #on_error, #on_open, #on_value, #subscribed?, #subscription!, #unsubscribe

Methods included from Subscription

#add, #add_resource, #subscribed?, #unsubscribe

Constructor Details

#initialize(subscriber) ⇒ FlatMapSubscription

Returns a new instance of FlatMapSubscription.



7
8
9
 
# File 'lib/reacto/subscriptions/flat_map_subscription.rb', line 7

def initialize(subscriber)
  super(nil, subscriber)
end

Instance Method Details

#on_value_subscriptions(v) ⇒ Object 



15
16
17
 
# File 'lib/reacto/subscriptions/flat_map_subscription.rb', line 15

def on_value_subscriptions(v)
  @subscriber.on_value(v)
end

#waiting? ⇒ Boolean

Returns:

  • (Boolean) 


11
12
13
 
# File 'lib/reacto/subscriptions/flat_map_subscription.rb', line 11

def waiting?
  false
end