class Reacto::Subscriptions::CombiningLastSubscription

Public Instance Methods

after_on_value(_) click to toggle source
# File lib/reacto/subscriptions/combining_last_subscription.rb, line 11
def after_on_value(_)
  return if @subscriptions.map(&:last_value).any? { |vl| vl == NO_VALUE }
  @subscriptions.each { |sub| sub.last_value = NO_VALUE }
end
on_close() click to toggle source
# File lib/reacto/subscriptions/combining_last_subscription.rb, line 16
def on_close
  return unless subscribed?
  @subscriber.on_close
end
subscribed?() click to toggle source
# File lib/reacto/subscriptions/combining_last_subscription.rb, line 7
def subscribed?
  @subscriptions.all? { |s| s.subscribed? }
end