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