diff --git a/lib/src/stream_subscription_transformer.dart b/lib/src/stream_subscription_transformer.dart
index 060f466..c13341c 100644
--- a/lib/src/stream_subscription_transformer.dart
+++ b/lib/src/stream_subscription_transformer.dart
@@ -5,7 +5,6 @@
 import 'dart:async';
 
 import 'async_memoizer.dart';
-import 'delegate/stream_subscription.dart';
 
 typedef Future _AsyncHandler<T>(StreamSubscription<T> inner);
 
@@ -101,5 +100,5 @@ class _TransformedSubscription<T> implements StreamSubscription<T> {
   }
 
   Future/*<E>*/ asFuture/*<E>*/([/*=E*/ futureValue]) =>
-      _inner?.asFuture(futureValue) ?? new Completer().future;
+      _inner?.asFuture(futureValue) ?? new Completer/*<E>*/().future;
 }