    @Test
    public void testConnect() throws MqttException {

        final MqttAndroidClient client = RxMqtt.client(RuntimeEnvironment.application, url);
        TestObserver observer = RxMqtt.connect(client).doOnNext(new Consumer<IMqttToken>() {
            @Override
            public void accept(IMqttToken token) throws Exception {
                System.out.println(token);
            }
        }).test();
        observer.awaitTerminalEvent();
        observer.assertTerminated();
    }