From 46f56872e5687487e3926c77b28a20aeb2a19e23 Mon Sep 17 00:00:00 2001
From: GroovieGermanikus <groovie@mango.markets>
Date: Fri, 19 Jan 2024 11:46:06 +0100
Subject: [PATCH] introduce T

---
 src/channel_plugger.rs | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/channel_plugger.rs b/src/channel_plugger.rs
index 12dad03..76c316b 100644
--- a/src/channel_plugger.rs
+++ b/src/channel_plugger.rs
@@ -5,9 +5,9 @@ use tokio::sync::mpsc::error::SendTimeoutError;
 use tokio::time::{sleep, timeout};
 
 
-pub fn spawn_plugger_mpcs_to_broadcast(
-    mut upstream: tokio::sync::mpsc::Receiver<u64>,
-    downstream: tokio::sync::broadcast::Sender<u64>,
+pub fn spawn_plugger_mpcs_to_broadcast<T: Send + 'static>(
+    mut upstream: tokio::sync::mpsc::Receiver<T>,
+    downstream: tokio::sync::broadcast::Sender<T>,
 ) {
     // abort forwarder by closing the sender
     let _donothing = tokio::spawn(async move {