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
combine_latest(*trackables, &block)
Alias for: combine
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