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/System.Reactive.Linq/Reactive/Internal/ConcatSink.cs')
-rw-r--r--Rx.NET/System.Reactive.Linq/Reactive/Internal/ConcatSink.cs29
1 files changed, 0 insertions, 29 deletions
diff --git a/Rx.NET/System.Reactive.Linq/Reactive/Internal/ConcatSink.cs b/Rx.NET/System.Reactive.Linq/Reactive/Internal/ConcatSink.cs
deleted file mode 100644
index 5f4a12f..0000000
--- a/Rx.NET/System.Reactive.Linq/Reactive/Internal/ConcatSink.cs
+++ /dev/null
@@ -1,29 +0,0 @@
-// Copyright (c) Microsoft Open Technologies, Inc. All rights reserved. See License.txt in the project root for license information.
-
-using System;
-using System.Collections.Generic;
-
-namespace System.Reactive
-{
- abstract class ConcatSink<TSource> : TailRecursiveSink<TSource>
- {
- public ConcatSink(IObserver<TSource> observer, IDisposable cancel)
- : base(observer, cancel)
- {
- }
-
- protected override IEnumerable<IObservable<TSource>> Extract(IObservable<TSource> source)
- {
- var concat = source as IConcatenatable<TSource>;
- if (concat != null)
- return concat.GetSources();
-
- return null;
- }
-
- public override void OnCompleted()
- {
- _recurse();
- }
- }
-}