Fix all strong-mode errors and warnings.

lib/src/isolate_channel.dart

 // Copyright (c) 2016, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 
 import 'dart:async';
 import 'dart:isolate';
 
 import 'package:async/async.dart';
 import 'package:stack_trace/stack_trace.dart';
 
@@ skipping 26 matching lines @@
   ///
   /// The connection protocol is guaranteed to remain compatible across versions
   /// at least until the next major version release. If the protocol is
   /// violated, the resulting channel will emit a single value on its stream and
   /// then close.
   factory IsolateChannel.connectReceive(ReceivePort receivePort) {
     // We can't use a [StreamChannelCompleter] here because we need the return
     // value to be an [IsolateChannel].
     var streamCompleter = new StreamCompleter<T>();
     var sinkCompleter = new StreamSinkCompleter<T>();
-    var channel = new IsolateChannel._(
+    var channel = new IsolateChannel<T>._(
         streamCompleter.stream, sinkCompleter.sink);
 
     // The first message across the ReceivePort should be a SendPort pointing to
     // the remote end. If it's not, we'll make the stream emit an error
     // complaining.
     var subscription;
     subscription = receivePort.listen((message) {
       if (message is SendPort) {
-        var controller = new StreamChannelController(
+        var controller = new StreamChannelController<T>(
             allowForeignErrors: false, sync: true);
-        new SubscriptionStream<T>(subscription).pipe(controller.local.sink);
-        controller.local.stream.listen(message.send,
+        new SubscriptionStream(subscription).pipe(controller.local.sink);
+        controller.local.stream.listen(
+            (data) => message.send(data),
             onDone: receivePort.close);
 
         streamCompleter.setSourceStream(controller.foreign.stream);
         sinkCompleter.setDestinationSink(controller.foreign.sink);
         return;
       }
 
       streamCompleter.setError(
           new StateError('Unexpected Isolate response "$message".'),
           new Trace.current());
@@ skipping 15 matching lines @@
   /// at least until the next major version release.
   factory IsolateChannel.connectSend(SendPort sendPort) {
     var receivePort = new ReceivePort();
     sendPort.send(receivePort.sendPort);
     return new IsolateChannel(receivePort, sendPort);
   }
 
   /// Creates a stream channel that receives messages from [receivePort] and
   /// sends them over [sendPort].
   factory IsolateChannel(ReceivePort receivePort, SendPort sendPort) {
-    var controller = new StreamChannelController(
+    var controller = new StreamChannelController<T>(
         allowForeignErrors: false, sync: true);
     receivePort.pipe(controller.local.sink);
-    controller.local.stream.listen(sendPort.send, onDone: receivePort.close);
+    controller.local.stream.listen(
+        (data) => sendPort.send(data),
+        onDone: receivePort.close);
     return new IsolateChannel._(
         controller.foreign.stream, controller.foreign.sink);
   }
 
   IsolateChannel._(this.stream, this.sink);
 }