From 8a3f478c386828e0ad3b7617aab46d7043726d71 Mon Sep 17 00:00:00 2001
From: Tangent 128 <Tangent128@gmail.com>
Date: Wed, 16 Oct 2019 00:16:47 -0400
Subject: [PATCH] Give Throttle a ::new() function for now

---
 src/fixers.rs | 18 ++++++++++++------
 1 file changed, 12 insertions(+), 6 deletions(-)

diff --git a/src/fixers.rs b/src/fixers.rs
index f134b73..dbbba52 100644
--- a/src/fixers.rs
+++ b/src/fixers.rs
@@ -99,6 +99,17 @@ pub struct Throttle<S> {
     sleep: Delay
 }
 
+impl<S> Throttle<S> {
+    pub fn new(wrap: S) -> Throttle<S> {
+        let now = Instant::now();
+        Throttle {
+            stream: wrap,
+            start_time: now,
+            sleep: delay(now)
+        }
+    }
+}
+
 impl<S: TryStream<Ok = Chunk, Error = WebmetroError> + Unpin> Stream for Throttle<S>
 {
     type Item = Result<Chunk, WebmetroError>;
@@ -138,12 +149,7 @@ pub trait ChunkStream where Self : Sized + TryStream<Ok = Chunk> {
     }
 
     fn throttle(self) -> Throttle<Self> {
-        let now = Instant::now();
-        Throttle {
-            stream: self,
-            start_time: now,
-            sleep: delay(now)
-        }
+        Throttle::new(self)
     }
 }