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/Where.cs')
-rw-r--r--Rx/NET/Source/System.Reactive.Linq/Reactive/Linq/Observable/Where.cs10
1 files changed, 5 insertions, 5 deletions
diff --git a/Rx/NET/Source/System.Reactive.Linq/Reactive/Linq/Observable/Where.cs b/Rx/NET/Source/System.Reactive.Linq/Reactive/Linq/Observable/Where.cs
index a8eaa92..3ab5f73 100644
--- a/Rx/NET/Source/System.Reactive.Linq/Reactive/Linq/Observable/Where.cs
+++ b/Rx/NET/Source/System.Reactive.Linq/Reactive/Linq/Observable/Where.cs
@@ -3,7 +3,7 @@
#if !NO_PERF
using System;
-namespace System.Reactive.Linq.Observαble
+namespace System.Reactive.Linq.ObservableImpl
{
class Where<TSource> : Producer<TSource>
{
@@ -23,7 +23,7 @@ namespace System.Reactive.Linq.Observαble
_predicateI = predicate;
}
- public IObservable<TSource> Ω(Func<TSource, bool> predicate)
+ public IObservable<TSource> Omega(Func<TSource, bool> predicate)
{
if (_predicate != null)
return new Where<TSource>(_source, x => _predicate(x) && predicate(x));
@@ -41,7 +41,7 @@ namespace System.Reactive.Linq.Observαble
}
else
{
- var sink = new τ(this, observer, cancel);
+ var sink = new WhereImpl(this, observer, cancel);
setSink(sink);
return _source.SubscribeSafe(sink);
}
@@ -88,12 +88,12 @@ namespace System.Reactive.Linq.Observαble
}
}
- class τ : Sink<TSource>, IObserver<TSource>
+ class WhereImpl : Sink<TSource>, IObserver<TSource>
{
private readonly Where<TSource> _parent;
private int _index;
- public τ(Where<TSource> parent, IObserver<TSource> observer, IDisposable cancel)
+ public WhereImpl(Where<TSource> parent, IObserver<TSource> observer, IDisposable cancel)
: base(observer, cancel)
{
_parent = parent;