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 .