class Reacto::Operations::Concat

Public Class Methods

new(trackable) click to toggle source

TODO Continue on error flag!

# File lib/reacto/operations/concat.rb, line 7
def initialize(trackable)
  @trackable = trackable
end

Public Instance Methods

call(tracker) click to toggle source
# File lib/reacto/operations/concat.rb, line 11
def call(tracker)
  Subscriptions::OperationSubscription.new(
    tracker,
    close: -> () { @trackable.send(:do_track, tracker) },
    error: -> (e) {
      tracker.on_error(e)
      @trackable.send(:do_track, tracker)
    }
  )
end