public void stream(@Nonnull final ApiStreamObserver<DocumentSnapshot> responseObserver) {
    stream(
        new QuerySnapshotObserver() {
          @Override
          public void onNext(QueryDocumentSnapshot documentSnapshot) {
            responseObserver.onNext(documentSnapshot);
          }

          @Override
          public void onError(Throwable throwable) {
            responseObserver.onError(throwable);
          }

          @Override
          public void onCompleted() {
            responseObserver.onCompleted();
          }
        },
        null);
  }
public void stream ( @ Nonnull final ApiStreamObserver < DocumentSnapshot > responseObserver ) { stream ( new QuerySnapshotObserver ( ) { @ Override public void onNext ( QueryDocumentSnapshot documentSnapshot ) { responseObserver . onNext ( documentSnapshot ) ; } @ Override public void onError ( Throwable throwable ) { responseObserver . onError ( throwable ) ; } @ Override public void onCompleted ( ) { responseObserver . onCompleted ( ) ; } } , null ) ; }
Executes the query and streams the results as a StreamObserver of DocumentSnapshots.

@param responseObserver The observer to be notified when results arrive.