Module: Rx

Defined in:: lib/rx/core/observer.rb,
lib/rx/version.rb,
lib/rx/joins/plan.rb,
lib/rx/internal/util.rb,
lib/rx/joins/pattern.rb,
lib/rx/operators/time.rb,
lib/rx/core/observable.rb,
lib/rx/operators/single.rb,
lib/rx/subjects/subject.rb,
lib/rx/testing/recorded.rb,
lib/rx/core/notification.rb,
lib/rx/joins/active_plan.rb,
lib/rx/core/time_interval.rb,
lib/rx/linq/observable/do.rb,
lib/rx/linq/observable/if.rb,
lib/rx/linq/observable/of.rb,
lib/rx/operators/creation.rb,
lib/rx/operators/multiple.rb,
lib/rx/joins/join_observer.rb,
lib/rx/linq/observable/and.rb,
lib/rx/linq/observable/for.rb,
lib/rx/linq/observable/case.rb,
lib/rx/linq/observable/from.rb,
lib/rx/linq/observable/when.rb,
lib/rx/operators/aggregates.rb,
lib/rx/concurrency/scheduler.rb,
lib/rx/core/checked_observer.rb,
lib/rx/linq/observable/delay.rb,
lib/rx/linq/observable/pairs.rb,
lib/rx/linq/observable/pluck.rb,
lib/rx/linq/observable/start.rb,
lib/rx/linq/observable/timer.rb,
lib/rx/linq/observable/while.rb,
lib/rx/testing/mock_observer.rb,
lib/rx/testing/reactive_test.rb,
lib/rx/concurrency/async_lock.rb,
lib/rx/subjects/async_subject.rb,
lib/rx/testing/hot_observable.rb,
lib/rx/testing/test_scheduler.rb,
lib/rx/core/scheduled_observer.rb,
lib/rx/internal/priority_queue.rb,
lib/rx/linq/observable/publish.rb,
lib/rx/subjects/replay_subject.rb,
lib/rx/testing/cold_observable.rb,
lib/rx/core/async_lock_observer.rb,
lib/rx/core/observe_on_observer.rb,
lib/rx/linq/observable/contains.rb,
lib/rx/linq/observable/debounce.rb,
lib/rx/linq/observable/to_async.rb,
lib/rx/core/auto_detach_observer.rb,
lib/rx/linq/observable/aggregate.rb,
lib/rx/linq/observable/fork_join.rb,
lib/rx/linq/observable/multicast.rb,
lib/rx/linq/observable/timestamp.rb,
lib/rx/operators/synchronization.rb,
lib/rx/subjects/behavior_subject.rb,
lib/rx/testing/test_subscription.rb,
lib/rx/concurrency/scheduled_item.rb,
lib/rx/core/synchronized_observer.rb,
lib/rx/linq/observable/concat_all.rb,
lib/rx/linq/observable/concat_map.rb,
lib/rx/linq/observable/group_join.rb,
lib/rx/subscriptions/subscription.rb,
lib/rx/concurrency/local_scheduler.rb,
lib/rx/linq/connectable_observable.rb,
lib/rx/subjects/subject_extensions.rb,
lib/rx/concurrency/default_scheduler.rb,
lib/rx/linq/observable/time_interval.rb,
lib/rx/concurrency/periodic_scheduler.rb,
lib/rx/concurrency/immediate_scheduler.rb,
lib/rx/concurrency/historical_scheduler.rb,
lib/rx/subscriptions/serial_subscription.rb,
lib/rx/concurrency/virtual_time_scheduler.rb,
lib/rx/operators/standard_query_operators.rb,
lib/rx/linq/observable/concat_map_observer.rb,
lib/rx/linq/observable/delay_with_selector.rb,
lib/rx/concurrency/current_thread_scheduler.rb,
lib/rx/subscriptions/composite_subscription.rb,
lib/rx/subscriptions/ref_count_subscription.rb,
lib/rx/subscriptions/scheduled_subscription.rb,
lib/rx/linq/observable/_observable_timer_time_span.rb,
lib/rx/subscriptions/single_assignment_subscription.rb,
lib/rx/linq/observable/_observable_timer_date_and_period.rb,
lib/rx/linq/observable/_observable_timer_time_span_and_period.rb

Overview

Defined Under Namespace

Modules: Notification, Observable, Observer, PeriodicScheduler, ReactiveTest, Scheduler, Subscription Classes: ActivePlan, AnonymousObservable, AnonymousSubscription, AsyncLock, AsyncLockObserver, AsyncSubject, AutoDetachObserver, BehaviorSubject, CheckedObserver, ColdObservable, CompositeSubscription, ConnectableObservable, CurrentThreadScheduler, DefaultScheduler, EmptySubscription, HistoricalScheduler, HotObservable, ImmediateScheduler, JoinObserver, LocalScheduler, MockObserver, ObserveOnObserver, ObserverBase, ObserverConfiguration, OnCompletedNotification, OnErrorNotification, OnNextNotification, Pattern, Plan, PriorityQueue, Recorded, RefCountSubscription, ReplaySubject, ScheduledDisposable, ScheduledItem, ScheduledObserver, SerialSubscription, SingleAssignmentSubscription, Subject, SynchronizedObserver, TestScheduler, TestSubscription, TimeInterval, VirtualTimeScheduler

Constant Summary collapse

VERSION =

'0.0.3'

Disposable =

Subscription