Welcome to mirror list, hosted at ThFree Co, Russian Federation.

github.com/mono/rx.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
Diffstat (limited to 'Rx/NET/Source/System.Reactive.Linq/Reactive/Linq/Observable/OnErrorResumeNext.cs')
-rw-r--r--Rx/NET/Source/System.Reactive.Linq/Reactive/Linq/Observable/OnErrorResumeNext.cs60
1 files changed, 60 insertions, 0 deletions
diff --git a/Rx/NET/Source/System.Reactive.Linq/Reactive/Linq/Observable/OnErrorResumeNext.cs b/Rx/NET/Source/System.Reactive.Linq/Reactive/Linq/Observable/OnErrorResumeNext.cs
new file mode 100644
index 0000000..26dfd34
--- /dev/null
+++ b/Rx/NET/Source/System.Reactive.Linq/Reactive/Linq/Observable/OnErrorResumeNext.cs
@@ -0,0 +1,60 @@
+// Copyright (c) Microsoft Open Technologies, Inc. All rights reserved. See License.txt in the project root for license information.
+
+#if !NO_PERF
+using System;
+using System.Collections.Generic;
+using System.Reactive.Concurrency;
+using System.Reactive.Disposables;
+
+namespace System.Reactive.Linq.Observαble
+{
+ class OnErrorResumeNext<TSource> : Producer<TSource>
+ {
+ private readonly IEnumerable<IObservable<TSource>> _sources;
+
+ public OnErrorResumeNext(IEnumerable<IObservable<TSource>> sources)
+ {
+ _sources = sources;
+ }
+
+ protected override IDisposable Run(IObserver<TSource> observer, IDisposable cancel, Action<IDisposable> setSink)
+ {
+ var sink = new _(observer, cancel);
+ setSink(sink);
+ return sink.Run(_sources);
+ }
+
+ class _ : TailRecursiveSink<TSource>
+ {
+ public _(IObserver<TSource> observer, IDisposable cancel)
+ : base(observer, cancel)
+ {
+ }
+
+ protected override IEnumerable<IObservable<TSource>> Extract(IObservable<TSource> source)
+ {
+ var oern = source as OnErrorResumeNext<TSource>;
+ if (oern != null)
+ return oern._sources;
+
+ return null;
+ }
+
+ public override void OnNext(TSource value)
+ {
+ base._observer.OnNext(value);
+ }
+
+ public override void OnError(Exception error)
+ {
+ _recurse();
+ }
+
+ public override void OnCompleted()
+ {
+ _recurse();
+ }
+ }
+ }
+}
+#endif \ No newline at end of file