Tomandersen/pipelines evaluate

firebase-firestore/firebase-firestore.gradle

@@ -142,6 +142,7 @@ dependencies {
     implementation libs.grpc.stub
     implementation libs.kotlin.stdlib
     implementation libs.kotlinx.coroutines.core
+    implementation 'com.google.re2j:re2j:1.6'
 
     compileOnly libs.autovalue.annotations
     compileOnly libs.javax.annotation.jsr250

firebase-firestore/src/main/java/com/google/firebase/firestore/DocumentReference.java

@@ -71,7 +71,7 @@ public final class DocumentReference {
   }
 
   /** @hide */
-  static DocumentReference forPath(ResourcePath path, FirebaseFirestore firestore) {
+  public static DocumentReference forPath(ResourcePath path, FirebaseFirestore firestore) {
     if (path.length() % 2 != 0) {
       throw new IllegalArgumentException(
           "Invalid document reference. Document references must have an even number "

firebase-firestore/src/main/java/com/google/firebase/firestore/FirebaseFirestore.java

@@ -894,4 +894,15 @@ public PipelineSource pipeline() {
     clientProvider.ensureConfigured();
     return new PipelineSource(this);
   }
+
+  /**
+   * Build a new RealtimePipeline
+   *
+   * @return {@code RealtimePipelineSource} for this Firestore instance.
+   */
+  @NonNull
+  public RealtimePipelineSource realtimePipeline() {
+    clientProvider.ensureConfigured();
+    return new RealtimePipelineSource(this);
+  }
 }

firebase-firestore/src/main/java/com/google/firebase/firestore/ListenerRegistration.java

@@ -14,6 +14,10 @@
 
 package com.google.firebase.firestore;
 
+import android.app.Activity;
+import androidx.annotation.NonNull;
+import com.google.firebase.firestore.core.ActivityScope;
+
 /** Represents a listener that can be removed by calling {@link #remove()}. */
 public interface ListenerRegistration {
 
@@ -22,4 +26,13 @@ public interface ListenerRegistration {
    * call, subsequent calls have no effect.
    */
   void remove();
+
+  /**
+   * The listener will be automatically removed during {@link Activity#onStop}.
+   *
+   * @param activity The activity to scope the listener to.
+   */
+  default void scope(@NonNull Activity activity) {
+    ActivityScope.bind(activity, this);
+  }
 }