Change integration test notifications to use structured objects.

pkg/analysis_server/tool/spec/codegen_inttest_methods.dart

 // Copyright (c) 2014, 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.
 
 /**
  * Code generation for the file "integration_test_methods.dart".
  */
 library codegenInttestMethods;
 
 import 'dart:convert';
@@ skipping 65 matching lines @@
       });
       writeln('}');
       writeln();
       docComment(toHtmlVisitor.collectHtml(() {
         toHtmlVisitor.writeln('Dispatch the notification named [event], and');
         toHtmlVisitor.writeln('containing parameters [params], to the');
         toHtmlVisitor.writeln('appropriate stream.');
       }));
       writeln('void dispatchNotification(String event, params) {');
       indent(() {
+        writeln('ResponseDecoder decoder = new ResponseDecoder(null);');
         writeln('switch (event) {');
         indent(() {
           write(notificationSwitchContents.join());
           writeln('default:');
           indent(() {
             writeln("fail('Unexpected notification: \$event');");
             writeln('break;');
           });
         });
         writeln('}');
       });
       writeln('}');
     });
     writeln('}');
   }
 
   @override
   visitNotification(Notification notification) {
     String streamName =
         camelJoin(['on', notification.domainName, notification.event]);
+    String className = camelJoin([notification.domainName, notification.event, 'params'], doCapitalize: true);
     writeln();
     docComment(toHtmlVisitor.collectHtml(() {
       toHtmlVisitor.translateHtml(notification.html);
       toHtmlVisitor.describePayload(notification.params, 'Parameters');
     }));
-    writeln('Stream $streamName;');
+    writeln('Stream<$className> $streamName;');
     writeln();
     docComment(toHtmlVisitor.collectHtml(() {
       toHtmlVisitor.write('Stream controller for [$streamName].');
     }));
-    writeln('StreamController _$streamName;');
+    writeln('StreamController<$className> _$streamName;');
     fieldInitializationCode.add(collectCode(() {
-      writeln('_$streamName = new StreamController(sync: true);');
+      writeln('_$streamName = new StreamController<$className>(sync: true);');
       writeln('$streamName = _$streamName.stream.asBroadcastStream();');
     }));
     notificationSwitchContents.add(collectCode(() {
       writeln('case ${JSON.encode(notification.longEvent)}:');
       indent(() {
         String paramsValidator =
             camelJoin(['is', notification.domainName, notification.event, 'params']);
         writeln('expect(params, $paramsValidator);');
-        writeln('_$streamName.add(params);');
+        String constructorCall;
+        if (notification.params == null) {
+          constructorCall = 'new $className()';
+        } else {
+          constructorCall = "new $className.fromJson(decoder, 'params', params)";
+        }
+        writeln('_$streamName.add($constructorCall);');
         writeln('break;');
       });
     }));
   }
 
   @override
   visitRequest(Request request) {
     String methodName = camelJoin(['send', request.domainName, request.method]);
     List<String> args = <String>[];
     List<String> optionalArgs = <String>[];
@@ skipping 111 matching lines @@
       new CodegenInttestMethodsVisitor(readApi());
   return visitor.collectCode(visitor.visitApi);
 });
 
 /**
  * Translate spec_input.html into protocol_matchers.dart.
  */
 main() {
   target.generate();
 }