  @Test public void shouldNotBeCompleted() {

    ObservableGroup group = observableManager.newGroup();
    TestObserver<Object> subscriber = new TestObserver<>();
    Observable<String> sourceObservable = Observable.never();

    sourceObservable.compose(group.transform(fooObserver)).subscribe(fooObserver);
    subscriber.assertNotComplete();
  }