Fix some extensions.

minidfx · Jun 17, 2015 · 1be5841 · 1be5841
1 parent 737687d
commit 1be5841
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/Rx.Contrib/ObservableExtensions.cs b/Rx.Contrib/ObservableExtensions.cs
@@ -214,7 +214,7 @@ public static IAwaitableSubscription AwaitableSubscription<TSource>(this IObserv
                                                                             Action<TSource> onNext,
                                                                             CancellationToken token)
         {
-            return new AwaitableSubscription<TSource>(source, token);
+            return new AwaitableSubscription<TSource>(source, onNext, token);
         }
 
         /// <summary>
@@ -243,7 +243,7 @@ public static IAwaitableSubscription AwaitableSubscription<TSource>(this IObserv
                                                                             Action<Exception> onError,
                                                                             CancellationToken token)
         {
-            return new AwaitableSubscription<TSource>(source, token);
+            return new AwaitableSubscription<TSource>(source, onNext, onError, token);
         }
 
         /// <summary>
@@ -272,7 +272,7 @@ public static IAwaitableSubscription AwaitableSubscription<TSource>(this IObserv
                                                                             Action onCompleted,
                                                                             CancellationToken token)
         {
-            return new AwaitableSubscription<TSource>(source, token);
+            return new AwaitableSubscription<TSource>(source, onNext, onCompleted, token);
         }
 
         /// <summary>
@@ -305,7 +305,7 @@ public static IAwaitableSubscription AwaitableSubscription<TSource>(this IObserv
                                                                             Action onCompleted,
                                                                             CancellationToken token)
         {
-            return new AwaitableSubscription<TSource>(source, token);
+            return new AwaitableSubscription<TSource>(source, onNext, onError, onCompleted, token);
         }
 
         #endregion