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