module Reacto
Constants
- DEFAULT_ON_ERROR
- FALSE_PREDICATE
- ID
- IDENTITY_ACTION
- NOTHING
- NO_ACTION
- NO_VALUE
- TRUE_PREDICATE
- VERSION
Public Instance Methods
[](object)
click to toggle source
# File lib/reacto.rb, line 67 def [](object) if object.is_a?(Enumerable) enumerable(object) elsif object.is_a?(StandardError) error(object) elsif object == :close close elsif object == :never || object.nil? never else value(object) end end
close(executor: nil)
click to toggle source
# File lib/reacto.rb, line 21 def close(executor: nil) Trackable.close(executor: executor) end
combine(*trackables, &block)
click to toggle source
# File lib/reacto.rb, line 51 def combine(*trackables, &block) Trackable.combine(*trackables, &block) end
Also aliased as: combine_latest
combine_last(*trackables, &block)
click to toggle source
# File lib/reacto.rb, line 55 def combine_last(*trackables, &block) Trackable.combine_last(*trackables, &block) end
concat(*trackables)
click to toggle source
# File lib/reacto.rb, line 63 def concat(*trackables) Trackable.concat(*trackables) end
enumerable(enumerable, executor: nil)
click to toggle source
# File lib/reacto.rb, line 33 def enumerable(enumerable, executor: nil) Trackable.enumerable(enumerable, executor: executor) end
error(err, executor: nil)
click to toggle source
# File lib/reacto.rb, line 25 def error(err, executor: nil) Trackable.error(err, executor: executor) end
interval( interval, enumerator = Behaviours.integers_enumerator, executor: nil )
click to toggle source
# File lib/reacto.rb, line 41 def interval( interval, enumerator = Behaviours.integers_enumerator, executor: nil ) Trackable.interval(interval, enumerator, executor: executor) end
later(secs, value, executor: :tasks)
click to toggle source
# File lib/reacto.rb, line 37 def later(secs, value, executor: :tasks) Trackable.later(secs, value, executor: executor) end
make(executor_param = nil, executor: executor, &block)
click to toggle source
# File lib/reacto.rb, line 13 def make(executor_param = nil, executor: executor, &block) Trackable.make(executor_param, executor: executor, &block) end
never()
click to toggle source
# File lib/reacto.rb, line 17 def never Trackable.never end
repeat(array, int: 0.1, executor: nil)
click to toggle source
# File lib/reacto.rb, line 47 def repeat(array, int: 0.1, executor: nil) Trackable.repeat(array, int: int, executor: executor) end
value(value, executor: nil)
click to toggle source
# File lib/reacto.rb, line 29 def value(value, executor: nil) Trackable.value(value, executor: executor) end
zip(*trackables, &block)
click to toggle source
# File lib/reacto.rb, line 59 def zip(*trackables, &block) Trackable.zip(*trackables, &block) end