class Reacto::Subscriptions::OperationSubscription

Public Class Methods

new( subscription, open: subscription.method(:on_open), value: subscription.method(:on_value), error: subscription.method(:on_error), close: subscription.method(:on_close) ) click to toggle source
Calls superclass method Reacto::Tracker::new
# File lib/reacto/subscriptions/operation_subscription.rb, line 12
def initialize(
  subscription,
  open: subscription.method(:on_open),
  value: subscription.method(:on_value),
  error: subscription.method(:on_error),
  close: subscription.method(:on_close)
)
  super(open: open, value: value, error: error, close: close)

  @wrapped = subscription
end