class Reacto::Subscriptions::FlatMapSubscription
Attributes
source_closed[RW]
Public Class Methods
new(subscriber)
click to toggle source
Calls superclass method
Reacto::Subscriptions::CompositeSubscription::new
# File lib/reacto/subscriptions/flat_map_subscription.rb, line 9 def initialize(subscriber) super(nil, subscriber) @source_closed = false end
Public Instance Methods
on_close()
click to toggle source
# File lib/reacto/subscriptions/flat_map_subscription.rb, line 23 def on_close return unless source_closed return unless subscribed? return unless @subscriptions.all? { |s| s.closed? } @subscriber.on_close unsubscribe end
on_value_subscriptions(v)
click to toggle source
# File lib/reacto/subscriptions/flat_map_subscription.rb, line 19 def on_value_subscriptions(v) @subscriber.on_value(v) end
waiting?()
click to toggle source
# File lib/reacto/subscriptions/flat_map_subscription.rb, line 15 def waiting? false end