| 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();
|
|
|