jt70

  @Test
  public void testSubscribeString(final TestContext ctx) throws Exception {
    final Async async = ctx.async();
    final EventBusClient client = client(ctx);
    client.consumer("client_addr", new Handler<Message<Object>>() {
      @Override
      public void handle(Message<Object> event) {
        ctx.assertEquals("hello", event.body());
        async.complete();
        client.close();

jt70

import 'package:flutter/material.dart';
import 'package:flutter/rendering.dart';
import 'package:intl/intl.dart' hide TextDirection;

void main() {
  runApp(new ChartDemo());
}

class ChartDemo extends StatelessWidget {
  @override

jt70

import 'dart:async';

import 'package:flutter/material.dart';

void main() {
  runApp(new MyApp());
}

class MyApp extends StatelessWidget {
  @override