class Reacto::Subscriptions::FlatMapSubscription

Attributes

source_closed[RW]

Public Class Methods

new(subscriber) click to toggle source
# 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