class Reacto::Operations::EachWithObject
Public Class Methods
new(action, obj)
click to toggle source
# File lib/reacto/operations/each_with_object.rb, line 6 def initialize(action, obj) @action = action @obj = obj end
Public Instance Methods
call(tracker)
click to toggle source
# File lib/reacto/operations/each_with_object.rb, line 11 def call(tracker) memo = @obj close = -> () do tracker.on_value(memo) tracker.on_close end error = -> (e) do tracker.on_value(memo) tracker.on_error(e) end Subscriptions::OperationSubscription.new( tracker, value: -> (v) { @action.call(v, memo) }, error: error, close: close ) end