Module: Reacto::Subscriptions

Defined in:
lib/reacto/subscriptions.rb,
lib/reacto/subscriptions/subscription.rb,
lib/reacto/subscriptions/inner_subscription.rb,
lib/reacto/subscriptions/simple_subscription.rb,
lib/reacto/subscriptions/subscription_wrapper.rb,
lib/reacto/subscriptions/tracker_subscription.rb,
lib/reacto/subscriptions/zipping_subscription.rb,
lib/reacto/subscriptions/buffered_subscription.rb,
lib/reacto/subscriptions/executor_subscription.rb,
lib/reacto/subscriptions/flat_map_subscription.rb,
lib/reacto/subscriptions/combining_subscription.rb,
lib/reacto/subscriptions/composite_subscription.rb,
lib/reacto/subscriptions/operation_subscription.rb,
lib/reacto/subscriptions/combining_last_subscription.rb

Defined Under Namespace

Modules: Subscription Classes: BufferedSubscription, CombiningLastSubscription, CombiningSubscription, CompositeSubscription, ExecutorSubscription, FlatMapSubscription, InnerSubscription, OperationSubscription, SimpleSubscription, SubscriptionWrapper, TrackerSubscription, ZippingSubscription

Class Method Summary collapse

Class Method Details

.on_close(&block) ⇒ Object 



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

def on_close(&block)
  SimpleSubscription.new(close: block)
end

.on_close_and_error(&block) ⇒ Object 



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

def on_close_and_error(&block)
  SimpleSubscription.new(
    close: -> () { block.call },
    error: -> (_e) { block.call }
  )
end