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