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_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_close ⇒ Object 



19
20
21
22
23
24
25
 
# File 'lib/reacto/subscriptions/flat_map_subscription.rb', line 19

def on_close
  return unless subscribed?
  return unless @subscriptions.any? { |s| !s.closed? }

  @subscriber.on_close
  unsubscribe
end

#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:



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

def waiting?
  false
end