diff --git a/Rx.NET/Source/src/System.Reactive/Linq/Observable/AsObservable.cs b/Rx.NET/Source/src/System.Reactive/Linq/Observable/AsObservable.cs
index 329cf2e24f..537d76d964 100644
--- a/Rx.NET/Source/src/System.Reactive/Linq/Observable/AsObservable.cs
+++ b/Rx.NET/Source/src/System.Reactive/Linq/Observable/AsObservable.cs
@@ -13,11 +13,6 @@ public AsObservable(IObservable<TSource> source)
             _source = source;
         }
 
-        public IObservable<TSource> Omega()
-        {
-            return this;
-        }
-
         public IObservable<TSource> Eval()
         {
             return _source;
diff --git a/Rx.NET/Source/src/System.Reactive/Linq/Observable/Cast.cs b/Rx.NET/Source/src/System.Reactive/Linq/Observable/Cast.cs
index c8a283ed4a..8f3b126679 100644
--- a/Rx.NET/Source/src/System.Reactive/Linq/Observable/Cast.cs
+++ b/Rx.NET/Source/src/System.Reactive/Linq/Observable/Cast.cs
@@ -4,7 +4,7 @@
 
 namespace System.Reactive.Linq.ObservableImpl
 {
-    internal sealed class Cast<TSource, TResult> : Producer<TResult> /* Could optimize further by deriving from Select<TResult> and providing Omega<TResult2>. We're not doing this (yet) for debuggability. */
+    internal sealed class Cast<TSource, TResult> : Producer<TResult> /* Could optimize further by deriving from Select<TResult> and providing Combine<TResult2>. We're not doing this (yet) for debuggability. */
     {
         private readonly IObservable<TSource> _source;
 
diff --git a/Rx.NET/Source/src/System.Reactive/Linq/Observable/IgnoreElements.cs b/Rx.NET/Source/src/System.Reactive/Linq/Observable/IgnoreElements.cs
index 6378de183b..62f9af9a2d 100644
--- a/Rx.NET/Source/src/System.Reactive/Linq/Observable/IgnoreElements.cs
+++ b/Rx.NET/Source/src/System.Reactive/Linq/Observable/IgnoreElements.cs
@@ -13,11 +13,6 @@ public IgnoreElements(IObservable<TSource> source)
             _source = source;
         }
 
-        public IObservable<TSource> Omega()
-        {
-            return this;
-        }
-
         protected override IDisposable Run(IObserver<TSource> observer, IDisposable cancel, Action<IDisposable> setSink)
         {
             var sink = new _(observer, cancel);
diff --git a/Rx.NET/Source/src/System.Reactive/Linq/Observable/Skip.cs b/Rx.NET/Source/src/System.Reactive/Linq/Observable/Skip.cs
index 0b3e0683e8..8d47d300fc 100644
--- a/Rx.NET/Source/src/System.Reactive/Linq/Observable/Skip.cs
+++ b/Rx.NET/Source/src/System.Reactive/Linq/Observable/Skip.cs
@@ -27,7 +27,7 @@ public Skip(IObservable<TSource> source, TimeSpan duration, IScheduler scheduler
             _scheduler = scheduler;
         }
 
-        public IObservable<TSource> Omega(int count)
+        public IObservable<TSource> Combine(int count)
         {
             //
             // Sum semantics:
@@ -39,7 +39,7 @@ public IObservable<TSource> Omega(int count)
             return new Skip<TSource>(_source, _count + count);
         }
 
-        public IObservable<TSource> Omega(TimeSpan duration)
+        public IObservable<TSource> Combine(TimeSpan duration)
         {
             //
             // Maximum semantics:
diff --git a/Rx.NET/Source/src/System.Reactive/Linq/Observable/SkipUntil.cs b/Rx.NET/Source/src/System.Reactive/Linq/Observable/SkipUntil.cs
index bc83eef16c..17b3ef9fae 100644
--- a/Rx.NET/Source/src/System.Reactive/Linq/Observable/SkipUntil.cs
+++ b/Rx.NET/Source/src/System.Reactive/Linq/Observable/SkipUntil.cs
@@ -139,7 +139,7 @@ public SkipUntil(IObservable<TSource> source, DateTimeOffset startTime, ISchedul
             _scheduler = scheduler;
         }
 
-        public IObservable<TSource> Omega(DateTimeOffset startTime)
+        public IObservable<TSource> Combine(DateTimeOffset startTime)
         {
             //
             // Maximum semantics:
diff --git a/Rx.NET/Source/src/System.Reactive/Linq/Observable/Take.cs b/Rx.NET/Source/src/System.Reactive/Linq/Observable/Take.cs
index 217137e334..bb0c406110 100644
--- a/Rx.NET/Source/src/System.Reactive/Linq/Observable/Take.cs
+++ b/Rx.NET/Source/src/System.Reactive/Linq/Observable/Take.cs
@@ -27,7 +27,7 @@ public Take(IObservable<TSource> source, TimeSpan duration, IScheduler scheduler
             _scheduler = scheduler;
         }
 
-        public IObservable<TSource> Omega(int count)
+        public IObservable<TSource> Combine(int count)
         {
             //
             // Minimum semantics:
@@ -42,7 +42,7 @@ public IObservable<TSource> Omega(int count)
                 return new Take<TSource>(_source, count);
         }
 
-        public IObservable<TSource> Omega(TimeSpan duration)
+        public IObservable<TSource> Combine(TimeSpan duration)
         {
             //
             // Minimum semantics:
diff --git a/Rx.NET/Source/src/System.Reactive/Linq/Observable/TakeUntil.cs b/Rx.NET/Source/src/System.Reactive/Linq/Observable/TakeUntil.cs
index cc5167e17a..a19ca7acbe 100644
--- a/Rx.NET/Source/src/System.Reactive/Linq/Observable/TakeUntil.cs
+++ b/Rx.NET/Source/src/System.Reactive/Linq/Observable/TakeUntil.cs
@@ -172,7 +172,7 @@ public TakeUntil(IObservable<TSource> source, DateTimeOffset endTime, IScheduler
             _scheduler = scheduler;
         }
 
-        public IObservable<TSource> Omega(DateTimeOffset endTime)
+        public IObservable<TSource> Combine(DateTimeOffset endTime)
         {
             //
             // Minimum semantics:
diff --git a/Rx.NET/Source/src/System.Reactive/Linq/Observable/Where.cs b/Rx.NET/Source/src/System.Reactive/Linq/Observable/Where.cs
index 1cbe2d600f..95bd47985a 100644
--- a/Rx.NET/Source/src/System.Reactive/Linq/Observable/Where.cs
+++ b/Rx.NET/Source/src/System.Reactive/Linq/Observable/Where.cs
@@ -22,7 +22,7 @@ public Where(IObservable<TSource> source, Func<TSource, int, bool> predicate)
             _predicateI = predicate;
         }
 
-        public IObservable<TSource> Omega(Func<TSource, bool> predicate)
+        public IObservable<TSource> Combine(Func<TSource, bool> predicate)
         {
             if (_predicate != null)
                 return new Where<TSource>(_source, x => _predicate(x) && predicate(x));
diff --git a/Rx.NET/Source/src/System.Reactive/Linq/QueryLanguage.Single.cs b/Rx.NET/Source/src/System.Reactive/Linq/QueryLanguage.Single.cs
index 06ce42503c..91e0681a4b 100644
--- a/Rx.NET/Source/src/System.Reactive/Linq/QueryLanguage.Single.cs
+++ b/Rx.NET/Source/src/System.Reactive/Linq/QueryLanguage.Single.cs
@@ -20,7 +20,7 @@ public virtual IObservable<TSource> AsObservable<TSource>(IObservable<TSource> s
         {
             var asObservable = source as AsObservable<TSource>;
             if (asObservable != null)
-                return asObservable.Omega();
+                return asObservable;
 
             return new AsObservable<TSource>(source);
         }
@@ -137,7 +137,7 @@ public virtual IObservable<TSource> IgnoreElements<TSource>(IObservable<TSource>
         {
             var ignoreElements = source as IgnoreElements<TSource>;
             if (ignoreElements != null)
-                return ignoreElements.Omega();
+                return ignoreElements;
 
             return new IgnoreElements<TSource>(source);
         }
diff --git a/Rx.NET/Source/src/System.Reactive/Linq/QueryLanguage.StandardSequenceOperators.cs b/Rx.NET/Source/src/System.Reactive/Linq/QueryLanguage.StandardSequenceOperators.cs
index c574b75371..6b2f40a78d 100644
--- a/Rx.NET/Source/src/System.Reactive/Linq/QueryLanguage.StandardSequenceOperators.cs
+++ b/Rx.NET/Source/src/System.Reactive/Linq/QueryLanguage.StandardSequenceOperators.cs
@@ -344,7 +344,7 @@ public virtual IObservable<TSource> Skip<TSource>(IObservable<TSource> source, i
         {
             var skip = source as Skip<TSource>;
             if (skip != null && skip._scheduler == null)
-                return skip.Omega(count);
+                return skip.Combine(count);
 
             return new Skip<TSource>(source, count);
         }
@@ -387,7 +387,7 @@ private static IObservable<TSource> Take_<TSource>(IObservable<TSource> source,
         {
             var take = source as Take<TSource>;
             if (take != null && take._scheduler == null)
-                return take.Omega(count);
+                return take.Combine(count);
 
             return new Take<TSource>(source, count);
         }
@@ -414,7 +414,7 @@ public virtual IObservable<TSource> Where<TSource>(IObservable<TSource> source,
         {
             var where = source as Where<TSource>;
             if (where != null)
-                return where.Omega(predicate);
+                return where.Combine(predicate);
 
             return new Where<TSource>(source, predicate);
         }
diff --git a/Rx.NET/Source/src/System.Reactive/Linq/QueryLanguage.Time.cs b/Rx.NET/Source/src/System.Reactive/Linq/QueryLanguage.Time.cs
index ed523ee050..3c380bd272 100644
--- a/Rx.NET/Source/src/System.Reactive/Linq/QueryLanguage.Time.cs
+++ b/Rx.NET/Source/src/System.Reactive/Linq/QueryLanguage.Time.cs
@@ -253,7 +253,7 @@ private static IObservable<TSource> Skip_<TSource>(IObservable<TSource> source,
         {
             var skip = source as Skip<TSource>;
             if (skip != null && skip._scheduler == scheduler)
-                return skip.Omega(duration);
+                return skip.Combine(duration);
 
             return new Skip<TSource>(source, duration, scheduler);
         }
@@ -295,7 +295,7 @@ private static IObservable<TSource> SkipUntil_<TSource>(IObservable<TSource> sou
         {
             var skipUntil = source as SkipUntil<TSource>;
             if (skipUntil != null && skipUntil._scheduler == scheduler)
-                return skipUntil.Omega(startTime);
+                return skipUntil.Combine(startTime);
 
             return new SkipUntil<TSource>(source, startTime, scheduler);
         }
@@ -318,7 +318,7 @@ private static IObservable<TSource> Take_<TSource>(IObservable<TSource> source,
         {
             var take = source as Take<TSource>;
             if (take != null && take._scheduler == scheduler)
-                return take.Omega(duration);
+                return take.Combine(duration);
 
             return new Take<TSource>(source, duration, scheduler);
         }
@@ -380,7 +380,7 @@ private static IObservable<TSource> TakeUntil_<TSource>(IObservable<TSource> sou
         {
             var takeUntil = source as TakeUntil<TSource>;
             if (takeUntil != null && takeUntil._scheduler == scheduler)
-                return takeUntil.Omega(endTime);
+                return takeUntil.Combine(endTime);
 
             return new TakeUntil<TSource>(source, endTime, scheduler);
         }