Table of Contents - rx-0.0.3 Documentation
Classes and Modules
- Enumerable
- Object
- Rx
- Rx::ActivePlan
- Rx::AnonymousObservable
- Rx::AnonymousSubscription
- Rx::AsyncLock
- Rx::AsyncLockObserver
- Rx::AsyncSubject
- Rx::AsyncSubject::InnerSubscription
- Rx::AutoDetachObserver
- Rx::BehaviorSubject
- Rx::BehaviorSubject::InnerSubscription
- Rx::CheckedObserver
- Rx::ColdObservable
- Rx::CompositeSubscription
- Rx::ConnectableObservable
- Rx::CurrentThreadScheduler
- Rx::DefaultScheduler
- Rx::Disposable
- Rx::EmptySubscription
- Rx::HistoricalScheduler
- Rx::HotObservable
- Rx::ImmediateScheduler
- Rx::ImmediateScheduler::AsyncLockScheduler
- Rx::JoinObserver
- Rx::LocalScheduler
- Rx::MockObserver
- Rx::Notification
- Rx::Observable
- Rx::Observable::AmbObserver
- Rx::Observable::HashConfiguration
- Rx::Observable::object;
- Rx::ObserveOnObserver
- Rx::Observer
- Rx::ObserverBase
- Rx::ObserverConfiguration
- Rx::OnCompletedNotification
- Rx::OnErrorNotification
- Rx::OnNextNotification
- Rx::Pattern
- Rx::PeriodicScheduler
- Rx::PeriodicScheduler::PeriodicTimer
- Rx::Plan
- Rx::PriorityQueue
- Rx::PriorityQueue::IndexedItem
- Rx::ReactiveTest
- Rx::ReactiveTest::OnErrorPredicate
- Rx::ReactiveTest::OnNextPredicate
- Rx::Recorded
- Rx::RefCountSubscription
- Rx::RefCountSubscription::InnerSubscription
- Rx::ReplaySubject
- Rx::ScheduledDisposable
- Rx::ScheduledItem
- Rx::ScheduledObserver
- Rx::Scheduler
- Rx::SerialSubscription
- Rx::SingleAssignmentSubscription
- Rx::Subject
- Rx::Subject::AnonymousSubject
- Rx::Subject::InnerSubscription
- Rx::Subscription
- Rx::SynchronizedObserver
- Rx::TestScheduler
- Rx::TestSubscription
- Rx::TimeInterval
- Rx::VirtualTimeScheduler
Methods
- ::allow_reentrancy — Rx::Observer
- ::amb — Rx::Observable
- ::case — Rx::Observable
- ::combine_latest — Rx::Observable
- ::concat — Rx::Observable
- ::configure — Rx::Observer
- ::create — Rx::Subject
- ::create — Rx::Observer
- ::create — Rx::Observable
- ::create — Rx::Subscription
- ::create — Rx::Subscription
- ::create_on_completed — Rx::Notification
- ::create_on_error — Rx::Notification
- ::create_on_next — Rx::Notification
- ::defer — Rx::Observable
- ::empty — Rx::Observable
- ::empty — Rx::Subscription
- ::empty — Rx::Subscription
- ::enumerable_select_with_index — Rx::Observable
- ::for — Rx::Observable
- ::fork_join — Rx::Observable
- ::from — Rx::Observable
- ::from_array — Rx::Observable
- ::from_notifier — Rx::Observer
- ::generate — Rx::Observable
- ::if — Rx::Observable
- ::interval — Rx::Observable
- ::just — Rx::Observable
- ::merge — Rx::Observable
- ::merge_all — Rx::Observable
- ::merge_concurrent — Rx::Observable
- ::never — Rx::Observable
- ::new — Rx::AsyncLock
- ::new — Rx::HistoricalScheduler
- ::new — Rx::ImmediateScheduler::AsyncLockScheduler
- ::new — Rx::PeriodicScheduler::PeriodicTimer
- ::new — Rx::ScheduledItem
- ::new — Rx::VirtualTimeScheduler
- ::new — Rx::AsyncLockObserver
- ::new — Rx::AutoDetachObserver
- ::new — Rx::CheckedObserver
- ::new — Rx::OnNextNotification
- ::new — Rx::OnErrorNotification
- ::new — Rx::OnCompletedNotification
- ::new — Rx::AnonymousObservable
- ::new — Rx::ObserveOnObserver
- ::new — Rx::ObserverConfiguration
- ::new — Rx::ObserverBase
- ::new — Rx::ScheduledObserver
- ::new — Rx::SynchronizedObserver
- ::new — Rx::TimeInterval
- ::new — Rx::PriorityQueue
- ::new — Rx::PriorityQueue::IndexedItem
- ::new — Rx::ActivePlan
- ::new — Rx::JoinObserver
- ::new — Rx::Pattern
- ::new — Rx::Plan
- ::new — Rx::ConnectableObservable
- ::new — Rx::Observable::HashConfiguration
- ::new — Rx::AsyncSubject
- ::new — Rx::AsyncSubject::InnerSubscription
- ::new — Rx::BehaviorSubject
- ::new — Rx::BehaviorSubject::InnerSubscription
- ::new — Rx::ReplaySubject
- ::new — Rx::Subject
- ::new — Rx::Subject::InnerSubscription
- ::new — Rx::Subject::AnonymousSubject
- ::new — Rx::CompositeSubscription
- ::new — Rx::RefCountSubscription
- ::new — Rx::RefCountSubscription::InnerSubscription
- ::new — Rx::ScheduledDisposable
- ::new — Rx::SerialSubscription
- ::new — Rx::SingleAssignmentSubscription
- ::new — Rx::AnonymousSubscription
- ::new — Rx::ColdObservable
- ::new — Rx::HotObservable
- ::new — Rx::MockObserver
- ::new — Rx::ReactiveTest::OnNextPredicate
- ::new — Rx::ReactiveTest::OnErrorPredicate
- ::new — Rx::Recorded
- ::new — Rx::TestScheduler
- ::new — Rx::TestSubscription
- ::normalize — Rx::Scheduler
- ::now — Rx::Scheduler
- ::observable_timer_date_and_period — Rx::Observable
- ::observable_timer_time_span — Rx::Observable
- ::observable_timer_time_span_and_period — Rx::Observable
- ::of — Rx::Observable
- ::of_array — Rx::Observable
- ::of_enumerable — Rx::Observable
- ::of_enumerator — Rx::Observable
- ::on_error_resume_next — Rx::Observable
- ::pairs — Rx::Observable
- ::prevent_reentrancy — Rx::Observer
- ::proc_bind — Rx::Observable
- ::queue — Rx::CurrentThreadScheduler
- ::queue= — Rx::CurrentThreadScheduler
- ::raise_error — Rx::Observable
- ::range — Rx::Observable
- ::repeat — Rx::Observable
- ::repeat_infinitely — Rx::Observable
- ::rescue_error — Rx::Observable
- ::return — Rx::Observable
- ::run_trampoline — Rx::CurrentThreadScheduler
- ::schedule_required? — Rx::CurrentThreadScheduler
- ::start — Rx::Observable
- ::switchCase — Rx::Observable
- ::timer — Rx::Observable
- ::to_async — Rx::Observable
- ::using — Rx::Observable
- ::when — Rx::Observable
- ::while — Rx::Observable
- ::zip — Rx::Observable
- #<< — Rx::CompositeSubscription
- #<=> — Rx::ScheduledItem
- #<=> — Rx::PriorityQueue::IndexedItem
- #== — Rx::OnNextNotification
- #== — Rx::OnErrorNotification
- #== — Rx::OnCompletedNotification
- #== — Rx::ReactiveTest::OnNextPredicate
- #== — Rx::ReactiveTest::OnErrorPredicate
- #_concat_map — Rx::Observable
- #_subscribe — Rx::Observable
- #accept — Rx::OnNextNotification
- #accept — Rx::OnErrorNotification
- #accept — Rx::OnCompletedNotification
- #activate — Rx::Plan
- #add — Rx::TestScheduler
- #add_active_plan — Rx::JoinObserver
- #add_ref — Rx::Observable
- #advance_by — Rx::VirtualTimeScheduler
- #advance_to — Rx::VirtualTimeScheduler
- #aggregate — Rx::Observable
- #all? — Rx::Observable
- #amb — Rx::Observable
- #and — Rx::Pattern
- #and — Rx::Observable
- #any? — Rx::Observable
- #as_observable — Rx::Observable
- #as_observer — Rx::Observer
- #assert_messages — Rx::ReactiveTest
- #assert_subscriptions — Rx::ReactiveTest
- #average — Rx::Observable
- #buffer_with_count — Rx::Observable
- #buffer_with_time — Rx::Observable
- #cancel — Rx::ScheduledItem
- #cancelled? — Rx::ScheduledItem
- #check_access — Rx::CheckedObserver
- #check_disposed — Rx::Subject
- #check_unsubscribed — Rx::AsyncSubject
- #check_unsubscribed — Rx::BehaviorSubject
- #checked — Rx::Observer
- #clear — Rx::AsyncLock
- #clear — Rx::CompositeSubscription
- #combine_latest — Rx::Observable
- #concat — Rx::Observable
- #concat_all — Rx::Observable
- #concat_map — Rx::Observable
- #concat_map_observer — Rx::Observable
- #configure — Rx::TestScheduler
- #connect — Rx::ConnectableObservable
- #contains — Rx::Observable
- #contains? — Rx::Observable
- #count — Rx::Observable
- #create_cold_observable — Rx::TestScheduler
- #create_hot_observable — Rx::TestScheduler
- #create_observer — Rx::TestScheduler
- #debounce — Rx::Observable
- #default_if_empty — Rx::Observable
- #delay — Rx::Observable
- #delay_date — Rx::Observable
- #delay_time_span — Rx::Observable
- #delay_with_selector — Rx::Observable
- #delete — Rx::PriorityQueue
- #delete — Rx::CompositeSubscription
- #delete_at — Rx::PriorityQueue
- #dematerialize — Rx::Observable
- #dequeue — Rx::ActivePlan
- #dispose — Rx::ObserverBase
- #dispose — Rx::Subscription
- #dispose — Rx::Subscription
- #distinct — Rx::Observable
- #distinct_until_changed — Rx::Observable
- #do — Rx::Observable
- #each — Rx::CompositeSubscription
- #element_at — Rx::Observable
- #element_at_or_default — Rx::Observable
- #empty? — Rx::Observable
- #enabled? — Rx::VirtualTimeScheduler
- #ensure_active — Rx::ScheduledObserver
- #ensures — Rx::Observable
- #enumerator_repeat_infinitely — Rx::Observable
- #enumerator_repeat_times — Rx::Observable
- #eql? — Rx::OnNextNotification
- #eql? — Rx::OnErrorNotification
- #eql? — Rx::OnCompletedNotification
- #eql? — Rx::ReactiveTest::OnNextPredicate
- #eql? — Rx::ReactiveTest::OnErrorPredicate
- #extrema_by — Rx::Observable
- #fail — Rx::ObserverBase
- #final — Rx::Observable
- #find_all — Rx::Observable
- #find_all_with_index — Rx::Observable
- #first — Rx::Observable
- #first_or_default — Rx::Observable
- #flat_map — Rx::Observable
- #flat_map_with_index — Rx::Observable
- #get_next — Rx::VirtualTimeScheduler
- #group_join — Rx::Observable
- #has_observers? — Rx::AsyncSubject
- #has_observers? — Rx::BehaviorSubject
- #has_observers? — Rx::ReplaySubject
- #has_observers? — Rx::Subject
- #has_value? — Rx::OnNextNotification
- #has_value? — Rx::Notification
- #heapify — Rx::PriorityQueue
- #ignore_elements — Rx::Observable
- #infinite? — Rx::TestSubscription
- #invoke — Rx::ScheduledItem
- #invoke — Rx::VirtualTimeScheduler
- #invoke — Rx::Scheduler
- #invoke_recursive — Rx::Scheduler
- #invoke_recursive_time — Rx::Scheduler
- #key_selector — Rx::Observable::HashConfiguration
- #last — Rx::Observable
- #last_or_default — Rx::Observable
- #latest — Rx::Observable
- #length — Rx::PriorityQueue
- #map — Rx::Observable
- #map_with_index — Rx::Observable
- #match — Rx::ActivePlan
- #materialize — Rx::Observable
- #max — Rx::Observable
- #max_by — Rx::Observable
- #merge — Rx::Observable
- #merge_all — Rx::Observable
- #merge_concurrent — Rx::Observable
- #method_missing — Rx::Observable::AmbObserver
- #min — Rx::Observable
- #min_by — Rx::Observable
- #multicast — Rx::Observable
- #none? — Rx::Observable
- #notify_on — Rx::Observer
- #now — Rx::LocalScheduler
- #now — Rx::VirtualTimeScheduler
- #observe_on — Rx::Observable
- #on_completed — Rx::CheckedObserver
- #on_completed — Rx::ObserverConfiguration
- #on_completed — Rx::ObserverBase
- #on_completed — Rx::AsyncSubject
- #on_completed — Rx::BehaviorSubject
- #on_completed — Rx::Subject
- #on_completed — Rx::Subject::AnonymousSubject
- #on_completed — Rx::MockObserver
- #on_completed — Rx::ReactiveTest
- #on_completed? — Rx::Notification
- #on_completed_core — Rx::AsyncLockObserver
- #on_completed_core — Rx::AutoDetachObserver
- #on_completed_core — Rx::ObserveOnObserver
- #on_completed_core — Rx::ScheduledObserver
- #on_completed_core — Rx::SynchronizedObserver
- #on_error — Rx::CheckedObserver
- #on_error — Rx::ObserverConfiguration
- #on_error — Rx::ObserverBase
- #on_error — Rx::AsyncSubject
- #on_error — Rx::BehaviorSubject
- #on_error — Rx::Subject
- #on_error — Rx::Subject::AnonymousSubject
- #on_error — Rx::MockObserver
- #on_error — Rx::ReactiveTest
- #on_error? — Rx::Notification
- #on_error_core — Rx::AsyncLockObserver
- #on_error_core — Rx::AutoDetachObserver
- #on_error_core — Rx::ObserveOnObserver
- #on_error_core — Rx::ScheduledObserver
- #on_error_core — Rx::SynchronizedObserver
- #on_error_predicate — Rx::ReactiveTest
- #on_error_resume_next — Rx::Observable
- #on_next — Rx::CheckedObserver
- #on_next — Rx::ObserverConfiguration
- #on_next — Rx::ObserverBase
- #on_next — Rx::AsyncSubject
- #on_next — Rx::BehaviorSubject
- #on_next — Rx::Subject
- #on_next — Rx::Subject::AnonymousSubject
- #on_next — Rx::MockObserver
- #on_next — Rx::ReactiveTest
- #on_next? — Rx::Notification
- #on_next_core — Rx::AsyncLockObserver
- #on_next_core — Rx::AutoDetachObserver
- #on_next_core — Rx::ObserveOnObserver
- #on_next_core — Rx::ScheduledObserver
- #on_next_core — Rx::SynchronizedObserver
- #on_next_predicate — Rx::ReactiveTest
- #peek — Rx::PriorityQueue
- #percolate — Rx::PriorityQueue
- #plan_create_observer — Rx::Plan
- #pluck — Rx::Observable
- #publish — Rx::Observable
- #push — Rx::PriorityQueue
- #push — Rx::CompositeSubscription
- #reduce — Rx::Observable
- #ref_count — Rx::ConnectableObservable
- #release — Rx::RefCountSubscription
- #remove_active_plan — Rx::JoinObserver
- #repeat — Rx::Observable
- #repeat_infinitely — Rx::Observable
- #require_all — Object
- #rescue_error — Rx::Observable
- #retry — Rx::Observable
- #retry_infinitely — Rx::Observable
- #run — Rx::ScheduledObserver
- #run_loop — Rx::PeriodicScheduler::PeriodicTimer
- #scan — Rx::Observable
- #schedule — Rx::Scheduler
- #schedule_absolute — Rx::Scheduler
- #schedule_absolute_with_state — Rx::LocalScheduler
- #schedule_absolute_with_state — Rx::VirtualTimeScheduler
- #schedule_at_absolute — Rx::VirtualTimeScheduler
- #schedule_at_absolute_with_state — Rx::VirtualTimeScheduler
- #schedule_at_absolute_with_state — Rx::TestScheduler
- #schedule_at_relative — Rx::VirtualTimeScheduler
- #schedule_at_relative_with_state — Rx::VirtualTimeScheduler
- #schedule_periodic — Rx::PeriodicScheduler
- #schedule_periodic_with_state — Rx::PeriodicScheduler
- #schedule_recursive — Rx::Scheduler
- #schedule_recursive_absolute — Rx::Scheduler
- #schedule_recursive_absolute_with_state — Rx::Scheduler
- #schedule_recursive_relative — Rx::Scheduler
- #schedule_recursive_relative_with_state — Rx::Scheduler
- #schedule_recursive_with_state — Rx::Scheduler
- #schedule_relative — Rx::Scheduler
- #schedule_relative_with_state — Rx::CurrentThreadScheduler
- #schedule_relative_with_state — Rx::DefaultScheduler
- #schedule_relative_with_state — Rx::ImmediateScheduler
- #schedule_relative_with_state — Rx::ImmediateScheduler::AsyncLockScheduler
- #schedule_relative_with_state — Rx::LocalScheduler
- #schedule_relative_with_state — Rx::VirtualTimeScheduler
- #schedule_subscribe — Rx::Observable
- #schedule_with_state — Rx::DefaultScheduler
- #schedule_with_state — Rx::ImmediateScheduler
- #schedule_with_state — Rx::ImmediateScheduler::AsyncLockScheduler
- #schedule_with_state — Rx::LocalScheduler
- #schedule_with_state — Rx::VirtualTimeScheduler
- #select — Rx::Observable
- #select_with_index — Rx::Observable
- #sequence_eql? — Rx::Observable
- #shift — Rx::PriorityQueue
- #single — Rx::Observable
- #single_or_default — Rx::Observable
- #skip — Rx::Observable
- #skip_last — Rx::Observable
- #skip_until — Rx::Observable
- #skip_while — Rx::Observable
- #skip_while_with_index — Rx::Observable
- #sleep — Rx::VirtualTimeScheduler
- #start — Rx::VirtualTimeScheduler
- #start_with — Rx::Observable
- #stop — Rx::VirtualTimeScheduler
- #subscribe — Rx::JoinObserver
- #subscribe — Rx::AsyncSubject
- #subscribe — Rx::BehaviorSubject
- #subscribe — Rx::Subject
- #subscribe — Rx::Subject::AnonymousSubject
- #subscribe — Rx::ColdObservable
- #subscribe — Rx::HotObservable
- #subscribe — Enumerable
- #subscribe — Rx::Observable
- #subscribe — Rx::ReactiveTest
- #subscribe_core — Rx::AnonymousObservable
- #subscribe_on — Rx::Observable
- #subscribe_on_completed — Rx::Observable
- #subscribe_on_error — Rx::Observable
- #subscribe_on_next — Rx::Observable
- #subscription — Rx::RefCountSubscription
- #subscription — Rx::SerialSubscription
- #subscription — Rx::SingleAssignmentSubscription
- #subscription= — Rx::AutoDetachObserver
- #subscription= — Rx::SerialSubscription
- #subscription= — Rx::SingleAssignmentSubscription
- #sum — Rx::Observable
- #synchronize — Rx::Observable
- #take — Rx::Observable
- #take_last — Rx::Observable
- #take_last_buffer — Rx::Observable
- #take_until — Rx::Observable
- #take_while — Rx::Observable
- #take_while_with_index — Rx::Observable
- #tap — Rx::Observable
- #then_do — Rx::Pattern
- #time_block — Rx::PeriodicScheduler::PeriodicTimer
- #time_interval — Rx::Observable
- #timestamp — Rx::Observable
- #to_a — Rx::Observable
- #to_h — Rx::Observable
- #to_notifier — Rx::Observer
- #to_observable — Enumerable
- #to_observable — Rx::Notification
- #to_relative — Rx::TestScheduler
- #to_s — Rx::OnNextNotification
- #to_s — Rx::OnErrorNotification
- #to_s — Rx::OnCompletedNotification
- #to_s — Rx::TimeInterval
- #to_s — Rx::Recorded
- #to_s — Rx::TestSubscription
- #to_time — Rx::TestScheduler
- #unsafe_peek — Rx::PriorityQueue
- #unsubscribe — Rx::PeriodicScheduler::PeriodicTimer
- #unsubscribe — Rx::AutoDetachObserver
- #unsubscribe — Rx::ObserveOnObserver
- #unsubscribe — Rx::ObserverBase
- #unsubscribe — Rx::ScheduledObserver
- #unsubscribe — Rx::JoinObserver
- #unsubscribe — Rx::AsyncSubject
- #unsubscribe — Rx::AsyncSubject::InnerSubscription
- #unsubscribe — Rx::BehaviorSubject
- #unsubscribe — Rx::BehaviorSubject::InnerSubscription
- #unsubscribe — Rx::Subject
- #unsubscribe — Rx::Subject::InnerSubscription
- #unsubscribe — Rx::CompositeSubscription
- #unsubscribe — Rx::RefCountSubscription
- #unsubscribe — Rx::RefCountSubscription::InnerSubscription
- #unsubscribe — Rx::ScheduledDisposable
- #unsubscribe — Rx::SerialSubscription
- #unsubscribe — Rx::SingleAssignmentSubscription
- #unsubscribe — Rx::EmptySubscription
- #unsubscribe — Rx::AnonymousSubscription
- #unsubscribe_observer — Rx::Subject
- #unsubscribed? — Rx::CompositeSubscription
- #unsubscribed? — Rx::RefCountSubscription
- #unsubscribed? — Rx::ScheduledDisposable
- #unsubscribed? — Rx::SerialSubscription
- #unsubscribed? — Rx::SingleAssignmentSubscription
- #value — Rx::BehaviorSubject
- #value_selector — Rx::Observable::HashConfiguration
- #wait — Rx::AsyncLock
- #window_with_count — Rx::Observable
- #window_with_time — Rx::Observable
- #zip — Rx::Observable