Table of Contents - reacto-1.0.0 Documentation
Classes and Modules
- Reacto
- Reacto::Behaviours
- Reacto::Cache
- Reacto::Cache::File
- Reacto::Cache::Memory
- Reacto::Executors
- Reacto::LabeledTrackable
- Reacto::Operations
- Reacto::Operations::Act
- Reacto::Operations::Append
- Reacto::Operations::BlockingEnumerable
- Reacto::Operations::Buffer
- Reacto::Operations::Chunk
- Reacto::Operations::ChunkWhile
- Reacto::Operations::Concat
- Reacto::Operations::Cycle
- Reacto::Operations::DelayEach
- Reacto::Operations::DelayEach::TaskObserver
- Reacto::Operations::DependOn
- Reacto::Operations::Diff
- Reacto::Operations::Drop
- Reacto::Operations::DropErrors
- Reacto::Operations::DropWhile
- Reacto::Operations::EachCollect
- Reacto::Operations::EachWithObject
- Reacto::Operations::Extremums
- Reacto::Operations::FindIndex
- Reacto::Operations::FlatMap
- Reacto::Operations::FlatMapLatest
- Reacto::Operations::Flatten
- Reacto::Operations::FlattenLabeled
- Reacto::Operations::GroupByLabel
- Reacto::Operations::Include
- Reacto::Operations::Inject
- Reacto::Operations::Last
- Reacto::Operations::Map
- Reacto::Operations::Merge
- Reacto::Operations::OperationOnLabeled
- Reacto::Operations::Partition
- Reacto::Operations::Prepend
- Reacto::Operations::RescueAndReplaceError
- Reacto::Operations::Retry
- Reacto::Operations::RetryWhen
- Reacto::Operations::Select
- Reacto::Operations::Slice
- Reacto::Operations::SliceWhen
- Reacto::Operations::SplitLabeled
- Reacto::Operations::Take
- Reacto::Operations::TakeWhile
- Reacto::Operations::Throttle
- Reacto::Operations::TrackOn
- Reacto::Operations::Uniq
- Reacto::Operations::Wrap
- Reacto::Resources
- Reacto::Resources::ExecutorResource
- Reacto::Resources::SharedResource
- Reacto::SharedTrackable
- Reacto::Subscriptions
- Reacto::Subscriptions::BufferedSubscription
- Reacto::Subscriptions::CombiningLastSubscription
- Reacto::Subscriptions::CombiningSubscription
- Reacto::Subscriptions::CompositeSubscription
- Reacto::Subscriptions::ExecutorSubscription
- Reacto::Subscriptions::FlatMapSubscription
- Reacto::Subscriptions::InnerSubscription
- Reacto::Subscriptions::OperationSubscription
- Reacto::Subscriptions::SimpleSubscription
- Reacto::Subscriptions::Subscription
- Reacto::Subscriptions::SubscriptionWrapper
- Reacto::Subscriptions::TrackerSubscription
- Reacto::Subscriptions::ZippingSubscription
- Reacto::Trackable
- Reacto::Tracker
Methods
- ::close — Reacto::Trackable
- ::combine — Reacto::Trackable
- ::combine_create — Reacto::Trackable
- ::combine_last — Reacto::Trackable
- ::combine_latest — Reacto::Trackable
- ::concat — Reacto::Trackable
- ::enumerable — Reacto::Trackable
- ::error — Reacto::Trackable
- ::interval — Reacto::Trackable
- ::later — Reacto::Trackable
- ::make — Reacto::Trackable
- ::never — Reacto::Trackable
- ::new — Reacto::Cache::File
- ::new — Reacto::Cache::Memory
- ::new — Reacto::LabeledTrackable
- ::new — Reacto::Operations::Act
- ::new — Reacto::Operations::Append
- ::new — Reacto::Operations::BlockingEnumerable
- ::new — Reacto::Operations::Buffer
- ::new — Reacto::Operations::Chunk
- ::new — Reacto::Operations::ChunkWhile
- ::new — Reacto::Operations::Concat
- ::new — Reacto::Operations::Cycle
- ::new — Reacto::Operations::DelayEach
- ::new — Reacto::Operations::DelayEach::TaskObserver
- ::new — Reacto::Operations::DependOn
- ::new — Reacto::Operations::Diff
- ::new — Reacto::Operations::Drop
- ::new — Reacto::Operations::DropWhile
- ::new — Reacto::Operations::EachCollect
- ::new — Reacto::Operations::EachWithObject
- ::new — Reacto::Operations::Extremums
- ::new — Reacto::Operations::FindIndex
- ::new — Reacto::Operations::FlatMap
- ::new — Reacto::Operations::FlatMapLatest
- ::new — Reacto::Operations::FlattenLabeled
- ::new — Reacto::Operations::GroupByLabel
- ::new — Reacto::Operations::Include
- ::new — Reacto::Operations::Inject
- ::new — Reacto::Operations::Last
- ::new — Reacto::Operations::Map
- ::new — Reacto::Operations::Merge
- ::new — Reacto::Operations::OperationOnLabeled
- ::new — Reacto::Operations::Partition
- ::new — Reacto::Operations::Prepend
- ::new — Reacto::Operations::RescueAndReplaceError
- ::new — Reacto::Operations::Retry
- ::new — Reacto::Operations::RetryWhen
- ::new — Reacto::Operations::Select
- ::new — Reacto::Operations::Slice
- ::new — Reacto::Operations::SliceWhen
- ::new — Reacto::Operations::SplitLabeled
- ::new — Reacto::Operations::Take
- ::new — Reacto::Operations::TakeWhile
- ::new — Reacto::Operations::Throttle
- ::new — Reacto::Operations::TrackOn
- ::new — Reacto::Operations::Wrap
- ::new — Reacto::Resources::ExecutorResource
- ::new — Reacto::Resources::SharedResource
- ::new — Reacto::SharedTrackable
- ::new — Reacto::Subscriptions::BufferedSubscription
- ::new — Reacto::Subscriptions::CompositeSubscription
- ::new — Reacto::Subscriptions::ExecutorSubscription
- ::new — Reacto::Subscriptions::FlatMapSubscription
- ::new — Reacto::Subscriptions::InnerSubscription
- ::new — Reacto::Subscriptions::OperationSubscription
- ::new — Reacto::Subscriptions::SimpleSubscription
- ::new — Reacto::Subscriptions::SubscriptionWrapper
- ::new — Reacto::Subscriptions::TrackerSubscription
- ::new — Reacto::Trackable
- ::new — Reacto::Tracker
- ::on_close — Reacto::Subscriptions
- ::on_close_and_error — Reacto::Subscriptions
- ::repeat — Reacto::Trackable
- ::shared_subscription — Reacto::Subscriptions
- ::value — Reacto::Trackable
- ::zip — Reacto::Trackable
- #[] — Reacto::Trackable
- #[] — Reacto
- #act — Reacto::Trackable
- #activate! — Reacto::SharedTrackable
- #activate_on_subscribe — Reacto::SharedTrackable
- #active? — Reacto::Subscriptions::BufferedSubscription
- #active? — Reacto::Subscriptions::InnerSubscription
- #add — Reacto::Subscriptions::CompositeSubscription
- #add — Reacto::Subscriptions::ExecutorSubscription
- #add — Reacto::Subscriptions::SimpleSubscription
- #add — Reacto::Subscriptions::TrackerSubscription
- #add — Reacto::Subscriptions::Subscription
- #add_resource — Reacto::Subscriptions::CompositeSubscription
- #add_resource — Reacto::Subscriptions::ExecutorSubscription
- #add_resource — Reacto::Subscriptions::SimpleSubscription
- #add_resource — Reacto::Subscriptions::TrackerSubscription
- #add_resource — Reacto::Subscriptions::Subscription
- #after_on_value — Reacto::Subscriptions::CombiningLastSubscription
- #after_on_value — Reacto::Subscriptions::CompositeSubscription
- #all? — Reacto::Trackable
- #any? — Reacto::Trackable
- #append — Reacto::Trackable
- #array_repeat_enumerator — Reacto::Behaviours
- #await — Reacto::Trackable
- #buffer — Reacto::Operations::DependOn
- #buffer — Reacto::Trackable
- #call — Reacto::Operations::Act
- #call — Reacto::Operations::Append
- #call — Reacto::Operations::BlockingEnumerable
- #call — Reacto::Operations::Buffer
- #call — Reacto::Operations::Chunk
- #call — Reacto::Operations::ChunkWhile
- #call — Reacto::Operations::Concat
- #call — Reacto::Operations::Cycle
- #call — Reacto::Operations::DelayEach
- #call — Reacto::Operations::DependOn
- #call — Reacto::Operations::Diff
- #call — Reacto::Operations::Drop
- #call — Reacto::Operations::DropErrors
- #call — Reacto::Operations::DropWhile
- #call — Reacto::Operations::EachCollect
- #call — Reacto::Operations::EachWithObject
- #call — Reacto::Operations::Extremums
- #call — Reacto::Operations::FindIndex
- #call — Reacto::Operations::FlatMap
- #call — Reacto::Operations::FlatMapLatest
- #call — Reacto::Operations::Flatten
- #call — Reacto::Operations::FlattenLabeled
- #call — Reacto::Operations::GroupByLabel
- #call — Reacto::Operations::Include
- #call — Reacto::Operations::Inject
- #call — Reacto::Operations::Last
- #call — Reacto::Operations::Map
- #call — Reacto::Operations::Merge
- #call — Reacto::Operations::OperationOnLabeled
- #call — Reacto::Operations::Partition
- #call — Reacto::Operations::Prepend
- #call — Reacto::Operations::RescueAndReplaceError
- #call — Reacto::Operations::Retry
- #call — Reacto::Operations::RetryWhen
- #call — Reacto::Operations::Select
- #call — Reacto::Operations::Slice
- #call — Reacto::Operations::SliceWhen
- #call — Reacto::Operations::SplitLabeled
- #call — Reacto::Operations::Take
- #call — Reacto::Operations::TakeWhile
- #call — Reacto::Operations::Throttle
- #call — Reacto::Operations::TrackOn
- #call — Reacto::Operations::Uniq
- #call — Reacto::Operations::Wrap
- #check_ready_and_track — Reacto::Operations::DependOn
- #chunk — Reacto::Trackable
- #chunk_while — Reacto::Trackable
- #cleanup — Reacto::Resources::ExecutorResource
- #cleanup — Reacto::Resources::SharedResource
- #close — Reacto
- #close_action — Reacto::Operations::Act
- #closed? — Reacto::Cache::File
- #closed? — Reacto::Cache::Memory
- #closed? — Reacto::Subscriptions::BufferedSubscription
- #closed? — Reacto::Subscriptions::CompositeSubscription
- #closed? — Reacto::Subscriptions::InnerSubscription
- #collect — Reacto::Trackable
- #collect_concat — Reacto::Trackable
- #combine — Reacto::Trackable
- #combine — Reacto
- #combine_last — Reacto::Trackable
- #combine_last — Reacto
- #combine_latest — Reacto::Trackable
- #combine_latest — Reacto
- #concat — Reacto::Trackable
- #concat — Reacto
- #constant — Reacto::Behaviours
- #count — Reacto::Trackable
- #count_and_delay_buffer_behaviour — Reacto::Operations::Buffer
- #count_buffer_behaviour — Reacto::Operations::Buffer
- #create_lifted — Reacto::LabeledTrackable
- #create_lifted — Reacto::Trackable
- #current — Reacto::Executors
- #current_value — Reacto::Subscriptions::ZippingSubscription
- #cycle — Reacto::Trackable
- #delay — Reacto::Trackable
- #delay_buffer_behaviour — Reacto::Operations::Buffer
- #delay_each — Reacto::Trackable
- #delay_task — Reacto::Operations::Buffer
- #delay_task — Reacto::Operations::DelayEach
- #delay_task — Reacto::Operations::Throttle
- #depend_on — Reacto::Trackable
- #deserialize — Reacto::Cache::File
- #detect — Reacto::Trackable
- #diff — Reacto::Trackable
- #do_track — Reacto::Trackable
- #drop — Reacto::Trackable
- #drop_errors — Reacto::Trackable
- #drop_while — Reacto::Trackable
- #each — Reacto::Cache::File
- #each — Reacto::Cache::Memory
- #each — Reacto::Trackable
- #each_cons — Reacto::Trackable
- #each_entry — Reacto::Trackable
- #each_slice — Reacto::Trackable
- #each_with_index — Reacto::Trackable
- #each_with_object — Reacto::Trackable
- #emit — Reacto::Operations::BlockingEnumerable
- #emit_trackables — Reacto::Operations::Partition
- #emit_values — Reacto::Operations::Extremums
- #emit_values — Reacto::Operations::GroupByLabel
- #entries — Reacto::Trackable
- #enumerable — Reacto
- #enumerable — Reacto::Behaviours
- #error — Reacto::Cache::File
- #error — Reacto::Cache::Memory
- #error — Reacto
- #error? — Reacto::Cache::File
- #error? — Reacto::Cache::Memory
- #error_action — Reacto::Operations::Act
- #execute_on — Reacto::Trackable
- #find — Reacto::Trackable
- #find_all — Reacto::Trackable
- #find_index — Reacto::Trackable
- #finish — Reacto::Operations::Buffer
- #finish — Reacto::Operations::Throttle
- #first — Reacto::Trackable
- #flat_map — Reacto::Trackable
- #flat_map_latest — Reacto::Trackable
- #flatten — Reacto::Trackable
- #flatten_labeled — Reacto::Trackable
- #flush — Reacto::Operations::DependOn
- #flush_current — Reacto::Operations::ChunkWhile
- #flush_current! — Reacto::Operations::Chunk
- #fresh? — Reacto::Cache::File
- #grep — Reacto::Trackable
- #grep_v — Reacto::Trackable
- #group_by — Reacto::Trackable
- #group_by_label — Reacto::Trackable
- #immediate — Reacto::Executors
- #include? — Reacto::Trackable
- #init_data — Reacto::Cache::File
- #inject — Reacto::Trackable
- #integers_enumerator — Reacto::Behaviours
- #interval — Reacto
- #io — Reacto::Executors
- #last — Reacto::Trackable
- #later — Reacto
- #lazy — Reacto::Trackable
- #lift — Reacto::Trackable
- #lift_behaviour — Reacto::Trackable
- #make — Reacto
- #map — Reacto::Trackable
- #max — Reacto::Trackable
- #max_by — Reacto::Trackable
- #merge — Reacto::Trackable
- #min — Reacto::Trackable
- #min_by — Reacto::Trackable
- #minmax — Reacto::Trackable
- #minmax_by — Reacto::Trackable
- #never — Reacto
- #new_thread — Reacto::Executors
- #none? — Reacto::Trackable
- #off — Reacto::SharedTrackable
- #off — Reacto::Trackable
- #on — Reacto::Trackable
- #on_close — Reacto::Cache::File
- #on_close — Reacto::Cache::Memory
- #on_close — Reacto::Subscriptions::CombiningLastSubscription
- #on_close — Reacto::Subscriptions::CompositeSubscription
- #on_close — Reacto::Subscriptions::ExecutorSubscription
- #on_close — Reacto::Subscriptions::FlatMapSubscription
- #on_close — Reacto::Subscriptions::SimpleSubscription
- #on_close — Reacto::Subscriptions::TrackerSubscription
- #on_close — Reacto::Subscriptions::ZippingSubscription
- #on_close — Reacto::Tracker
- #on_error — Reacto::Cache::File
- #on_error — Reacto::Cache::Memory
- #on_error — Reacto::Subscriptions::CompositeSubscription
- #on_error — Reacto::Subscriptions::ExecutorSubscription
- #on_error — Reacto::Subscriptions::SimpleSubscription
- #on_error — Reacto::Subscriptions::TrackerSubscription
- #on_error — Reacto::Tracker
- #on_open — Reacto::Subscriptions::CompositeSubscription
- #on_open — Reacto::Subscriptions::ExecutorSubscription
- #on_open — Reacto::Subscriptions::SimpleSubscription
- #on_open — Reacto::Subscriptions::TrackerSubscription
- #on_open — Reacto::Tracker
- #on_value — Reacto::Cache::File
- #on_value — Reacto::Cache::Memory
- #on_value — Reacto::Subscriptions::CompositeSubscription
- #on_value — Reacto::Subscriptions::ExecutorSubscription
- #on_value — Reacto::Subscriptions::SimpleSubscription
- #on_value — Reacto::Subscriptions::TrackerSubscription
- #on_value — Reacto::Tracker
- #on_value_subscriptions — Reacto::Subscriptions::CompositeSubscription
- #on_value_subscriptions — Reacto::Subscriptions::FlatMapSubscription
- #on_value_subscriptions — Reacto::Subscriptions::ZippingSubscription
- #one? — Reacto::Trackable
- #partition — Reacto::Trackable
- #passed — Reacto::Operations::Uniq
- #prepend — Reacto::Trackable
- #ready? — Reacto::Cache::File
- #ready? — Reacto::Cache::Memory
- #reduce — Reacto::Trackable
- #reject — Reacto::Trackable
- #relabel — Reacto::LabeledTrackable
- #repeat — Reacto
- #rescue_and_replace_error — Reacto::Trackable
- #rescue_and_replace_error_with — Reacto::Trackable
- #retrieve_executor — Reacto::Trackable
- #retry — Reacto::Trackable
- #retry_when — Reacto::Trackable
- #same_predicate — Reacto::Behaviours
- #select — Reacto::Trackable
- #select_map — Reacto::Trackable
- #serialize — Reacto::Cache::File
- #shared_subscription — Reacto::SharedTrackable
- #single_tracker_value — Reacto::Behaviours
- #single_value — Reacto::Behaviours
- #skip — Reacto::Trackable
- #skip_errors — Reacto::Trackable
- #slice — Reacto::Trackable
- #slice_after — Reacto::Trackable
- #slice_before — Reacto::Trackable
- #slice_when — Reacto::Trackable
- #sort — Reacto::Trackable
- #sort_by — Reacto::Trackable
- #split_labeled — Reacto::Trackable
- #subscribed? — Reacto::Subscriptions::CombiningLastSubscription
- #subscribed? — Reacto::Subscriptions::CompositeSubscription
- #subscribed? — Reacto::Subscriptions::ExecutorSubscription
- #subscribed? — Reacto::Subscriptions::SimpleSubscription
- #subscribed? — Reacto::Subscriptions::TrackerSubscription
- #subscribed? — Reacto::Subscriptions::ZippingSubscription
- #subscribed? — Reacto::Subscriptions::Subscription
- #subscription! — Reacto::Subscriptions::CompositeSubscription
- #subscription! — Reacto::Subscriptions::ZippingSubscription
- #take — Reacto::Trackable
- #take_while — Reacto::Trackable
- #tasks — Reacto::Executors
- #throttle — Reacto::Trackable
- #to_a — Reacto::Trackable
- #to_h — Reacto::Trackable
- #track — Reacto::SharedTrackable
- #track — Reacto::Trackable
- #track_on — Reacto::Trackable
- #uniq — Reacto::Trackable
- #unsubscribe — Reacto::Subscriptions::CompositeSubscription
- #unsubscribe — Reacto::Subscriptions::ExecutorSubscription
- #unsubscribe — Reacto::Subscriptions::InnerSubscription
- #unsubscribe — Reacto::Subscriptions::SimpleSubscription
- #unsubscribe — Reacto::Subscriptions::TrackerSubscription
- #unsubscribe — Reacto::Subscriptions::Subscription
- #update — Reacto::Operations::DelayEach::TaskObserver
- #value — Reacto
- #value_action — Reacto::Operations::Act
- #waiting? — Reacto::Subscriptions::CompositeSubscription
- #waiting? — Reacto::Subscriptions::FlatMapSubscription
- #waiting? — Reacto::Subscriptions::ZippingSubscription
- #with_close_and_error — Reacto::Behaviours
- #wrap — Reacto::Trackable
- #zip — Reacto::Trackable
- #zip — Reacto