class Reacto::Operations::Include
Public Class Methods
new(value)
click to toggle source
# File lib/reacto/operations/include.rb, line 7 def initialize(value) @value = value end
Public Instance Methods
call(tracker)
click to toggle source
# File lib/reacto/operations/include.rb, line 11 def call(tracker) includes = false behaviour = -> (val) do if @value == val includes = true tracker.on_value(includes) tracker.on_close end end close = -> () do tracker.on_value(includes) unless includes tracker.on_close end error = -> (e) do tracker.on_value(includes) unless includes tracker.on_error(e) end Subscriptions::OperationSubscription.new( tracker, value: behaviour, error: error, close: close ) end