From a8083105f5dfe7e8390eb1959aaeef2109ae31bb Mon Sep 17 00:00:00 2001
From: Evan Simmons <evan.simmons@prevoty.com>
Date: Fri, 8 Apr 2022 11:51:57 -0700
Subject: [PATCH] Add subscribe method to broadcast::Receiver

---
 tokio/src/sync/broadcast.rs | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/tokio/src/sync/broadcast.rs b/tokio/src/sync/broadcast.rs
index e54fe5c8151..229ba512c5a 100644
--- a/tokio/src/sync/broadcast.rs
+++ b/tokio/src/sync/broadcast.rs
@@ -758,6 +758,13 @@ impl<T> Receiver<T> {
         self.len() == 0
     }
 
+    /// Creates a new [`Receiver`] handle that will receive values sent **after**
+    /// this call to `subscribe`.
+    pub fn subscribe(&self) -> Self {
+        let shared = self.shared.clone();
+        new_receiver(shared)
+    }
+
     /// Locks the next value if there is one.
     fn recv_ref(
         &mut self,