diff options
author | Atsushi Eno <atsushieno@veritas-vos-liberabit.com> | 2012-11-12 22:47:31 +0400 |
---|---|---|
committer | Atsushi Eno <atsushieno@veritas-vos-liberabit.com> | 2012-11-12 22:52:17 +0400 |
commit | d1174f3f8979321a9182925df460e07e08157b41 (patch) | |
tree | d16fb2fc191bf68ff0e2aac600adf71aba8cad01 /Rx.NET/System.Reactive.Linq/Reactive/Linq/QueryLanguage.Concurrency.cs | |
parent | d90a52595e24b1216c89f6cb5f245262db1810ae (diff) |
partial import of ca05fdeb565e: Reactive Extensions OSS V1.0
Diffstat (limited to 'Rx.NET/System.Reactive.Linq/Reactive/Linq/QueryLanguage.Concurrency.cs')
-rw-r--r-- | Rx.NET/System.Reactive.Linq/Reactive/Linq/QueryLanguage.Concurrency.cs | 61 |
1 files changed, 61 insertions, 0 deletions
diff --git a/Rx.NET/System.Reactive.Linq/Reactive/Linq/QueryLanguage.Concurrency.cs b/Rx.NET/System.Reactive.Linq/Reactive/Linq/QueryLanguage.Concurrency.cs new file mode 100644 index 0000000..58408b2 --- /dev/null +++ b/Rx.NET/System.Reactive.Linq/Reactive/Linq/QueryLanguage.Concurrency.cs @@ -0,0 +1,61 @@ +// Copyright (c) Microsoft Open Technologies, Inc. All rights reserved. See License.txt in the project root for license information. + +using System.Reactive.Concurrency; +using System.Reactive.Disposables; +using System.Threading; + +namespace System.Reactive.Linq +{ +#if !NO_PERF + using Observαble; +#endif + + internal partial class QueryLanguage + { + #region + ObserveOn + + + public virtual IObservable<TSource> ObserveOn<TSource>(IObservable<TSource> source, IScheduler scheduler) + { + return Synchronization.ObserveOn<TSource>(source, scheduler); + } + +#if !NO_SYNCCTX + public virtual IObservable<TSource> ObserveOn<TSource>(IObservable<TSource> source, SynchronizationContext context) + { + return Synchronization.ObserveOn<TSource>(source, context); + } +#endif + + #endregion + + #region + SubscribeOn + + + public virtual IObservable<TSource> SubscribeOn<TSource>(IObservable<TSource> source, IScheduler scheduler) + { + return Synchronization.SubscribeOn<TSource>(source, scheduler); + } + +#if !NO_SYNCCTX + public virtual IObservable<TSource> SubscribeOn<TSource>(IObservable<TSource> source, SynchronizationContext context) + { + return Synchronization.SubscribeOn<TSource>(source, context); + } +#endif + + #endregion + + #region + Synchronize + + + public virtual IObservable<TSource> Synchronize<TSource>(IObservable<TSource> source) + { + return Synchronization.Synchronize(source); + } + + public virtual IObservable<TSource> Synchronize<TSource>(IObservable<TSource> source, object gate) + { + return Synchronization.Synchronize(source, gate); + } + + #endregion + } +} |