diff --git a/Firestore/Source/Public/FirebaseFirestore/FIRCallbackWrapper.h b/Firestore/Source/Public/FirebaseFirestore/FIRCallbackWrapper.h
index d5ae24f1602..68b4c2d370b 100644
--- a/Firestore/Source/Public/FirebaseFirestore/FIRCallbackWrapper.h
+++ b/Firestore/Source/Public/FirebaseFirestore/FIRCallbackWrapper.h
@@ -52,7 +52,7 @@ NS_SWIFT_NAME(CallbackWrapper)
 // are invoked on a different thread than the one they were originally defined in. If this callback
 // is expected to be called on a different thread, it should be marked as `Sendable` to ensure
 // thread safety.
-+ (std::unique_ptr<core::EventListener<std::vector<api::PipelineResult>>>)
++ (std::shared_ptr<core::EventListener<std::vector<api::PipelineResult>>>)
     wrapPipelineCallback:(std::shared_ptr<api::Firestore>)firestore
               completion:(void (^NS_SWIFT_SENDABLE)(
                              std::shared_ptr<std::vector<api::PipelineResult>> result,
diff --git a/Firestore/core/interfaceForSwift/api/pipeline.h b/Firestore/core/interfaceForSwift/api/pipeline.h
index 374d2d2d460..fb495382490 100644
--- a/Firestore/core/interfaceForSwift/api/pipeline.h
+++ b/Firestore/core/interfaceForSwift/api/pipeline.h
@@ -35,7 +35,7 @@ class Firestore;
 class PipelineResult;
 
 using PipelineSnapshotListener =
-    std::unique_ptr<core::EventListener<std::vector<PipelineResult>>>;
+    std::shared_ptr<core::EventListener<std::vector<PipelineResult>>>;
 
 class Pipeline {
  public: