class Reacto::Operations::Uniq

Public Instance Methods

call(tracker) click to toggle source
# File lib/reacto/operations/uniq.rb, line 10
def call(tracker)
  value = lambda do |v|
    unless passed[v]
      passed[v] = true
      tracker.on_value(v)
    end
  end

  Subscriptions::OperationSubscription.new(tracker, value: value)
end
passed() click to toggle source
# File lib/reacto/operations/uniq.rb, line 6
def passed
  @passed ||= {}
end