File tree Expand file tree Collapse file tree 2 files changed +9
-1
lines changed
src/main/java/com/google/cloud/firestore Expand file tree Collapse file tree 2 files changed +9
-1
lines changed Original file line number Diff line number Diff line change 314314 <method >com.google.cloud.firestore.Query getQuery()</method >
315315 </difference >
316316
317+ <difference >
318+ <className >com/google/cloud/firestore/StreamableQuery</className >
319+ <differenceType >7009</differenceType >
320+ <method >void internalStream(*)</method >
321+ </difference >
322+
317323</differences >
Original file line number Diff line number Diff line change 2020import static com .google .common .collect .Lists .reverse ;
2121
2222import com .google .api .core .ApiFuture ;
23+ import com .google .api .core .InternalApi ;
2324import com .google .api .core .SettableApiFuture ;
2425import com .google .api .gax .rpc .ApiStreamObserver ;
2526import com .google .api .gax .rpc .ResponseObserver ;
4950 * `isRetryableWithCursor`. Retrying with a cursor means that the StreamableQuery can be resumed
5051 * where it failed by first calling `startAfter(lastDocumentReceived)`.
5152 */
53+ @ InternalApi
5254public abstract class StreamableQuery <SnapshotType > {
5355 final Query .QueryOptions options ;
5456 final FirestoreRpcContext <?> rpcContext ;
@@ -237,7 +239,7 @@ public void onCompleted() {
237239 }
238240 }
239241
240- protected void internalStream (
242+ void internalStream (
241243 final ApiStreamObserver <RunQueryResponse > runQueryResponseObserver ,
242244 final long startTimeNanos ,
243245 @ Nullable final ByteString transactionId ,
You can’t perform that action at this time.
0 commit comments