source: class RxMqttClientTest {
  
       FakeMqttClient fakeMqttClient;
       RxMqttClient rxclient;
       MessageRecordingObserver mo;
       StatusRecordingObserver so;
       PublishResponseRecordingObserver pro;
  
      @Test
      public void testStatusConnected() {
  
target:         rxclient.status().subscribe(so);
  
          so.assertStatus()
                  .hasState(CONNECTED);
  
          so.assertNoMoreEvents();
      }
  
  }