Index: lib/src/disconnector.dart |
diff --git a/lib/src/disconnector.dart b/lib/src/disconnector.dart |
index 35ecd1cc408305e34feec605e1251fced3747c38..beff71dd0e3e766562eb89535ab6e0855b5bc64a 100644 |
--- a/lib/src/disconnector.dart |
+++ b/lib/src/disconnector.dart |
@@ -38,7 +38,7 @@ class Disconnector<T> implements StreamChannelTransformer<T, T> { |
StreamChannel<T> bind(StreamChannel<T> channel) { |
return channel.changeSink((innerSink) { |
- var sink = new _DisconnectorSink(innerSink); |
+ var sink = new _DisconnectorSink<T>(innerSink); |
if (_isDisconnected) { |
sink._disconnect(); |