class Reacto::Operations::Select

Public Class Methods

new(filter) click to toggle source
# File lib/reacto/operations/select.rb, line 6
def initialize(filter)
  @filter = filter
end

Public Instance Methods

call(tracker) click to toggle source
# File lib/reacto/operations/select.rb, line 10
def call(tracker)
  behaviour = -> (v) do
    if @filter.call(v)
      tracker.on_value(v)
    end
  end

  Subscriptions::OperationSubscription.new(tracker, value: behaviour)
end