diff --git a/Rx.Contrib/ObservableExtensions.cs b/Rx.Contrib/ObservableExtensions.cs
index 8a42e39..4bf2cc5 100644
--- 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