delete #[test]s from streams

Author: pchickey

src/stream/buffer.rs

@@ -98,44 +98,3 @@ impl<S: Stream, I: Stream> Stream for Buffer<S, I> {
         }
     }
 }
-
-#[cfg(test)]
-mod test {
-    use crate::prelude::*;
-    use crate::time::Duration;
-    use futures_lite::prelude::*;
-
-    #[test]
-    fn buffer_all_values() {
-        crate::runtime::block_on(async {
-            let interval = Duration::from_millis(5);
-            let buffer = Duration::from_millis(20);
-
-            let mut counter = 0;
-            crate::stream::interval(interval)
-                .take(10)
-                .buffer(buffer)
-                .for_each(|buf| counter += buf.len())
-                .await;
-
-            assert_eq!(counter, 10);
-        })
-    }
-
-    #[test]
-    fn no_debounces_hit() {
-        crate::runtime::block_on(async {
-            let interval = Duration::from_millis(20);
-            let buffer = Duration::from_millis(10);
-
-            let mut counter = 0;
-            crate::stream::interval(interval)
-                .take(10)
-                .buffer(buffer)
-                .for_each(|buf| counter += buf.len())
-                .await;
-
-            assert_eq!(counter, 10);
-        })
-    }
-}

src/stream/debounce.rs

@@ -102,44 +102,3 @@ where
         }
     }
 }
-
-#[cfg(test)]
-mod test {
-    use crate::prelude::*;
-    use crate::time::Duration;
-    use futures_lite::prelude::*;
-
-    #[test]
-    fn all_values_debounce() {
-        crate::runtime::block_on(async {
-            let interval = Duration::from_millis(10);
-            let debounce = Duration::from_millis(20);
-
-            let mut counter = 0;
-            crate::stream::interval(interval)
-                .take(10)
-                .debounce(debounce)
-                .for_each(|_| counter += 1)
-                .await;
-
-            assert_eq!(counter, 1);
-        })
-    }
-
-    #[test]
-    fn no_debounces_hit() {
-        crate::runtime::block_on(async {
-            let interval = Duration::from_millis(40);
-            let debounce = Duration::from_millis(10);
-
-            let mut counter = 0;
-            crate::stream::interval(interval)
-                .take(10)
-                .debounce(debounce)
-                .for_each(|_| counter += 1)
-                .await;
-
-            assert_eq!(counter, 10);
-        })
-    }
-}

src/stream/sample.rs

@@ -97,30 +97,3 @@ impl<S: Stream, I: Stream> Stream for Sample<S, I> {
         }
     }
 }
-
-#[cfg(test)]
-mod test {
-    use crate::prelude::*;
-    use crate::time::Duration;
-    use futures_lite::prelude::*;
-
-    #[test]
-    fn smoke() {
-        crate::runtime::block_on(async {
-            let interval = Duration::from_millis(100);
-            let throttle = Duration::from_millis(200);
-
-            let take = 4;
-            let expected = 2;
-
-            let mut counter = 0;
-            crate::stream::interval(interval)
-                .take(take)
-                .sample(throttle)
-                .for_each(|_| counter += 1)
-                .await;
-
-            assert_eq!(counter, expected);
-        })
-    }
-}

src/stream/throttle.rs

@@ -100,30 +100,3 @@ impl<S: Stream, I: Stream> Stream for Throttle<S, I> {
         }
     }
 }
-
-#[cfg(test)]
-mod test {
-    use crate::prelude::*;
-    use crate::time::Duration;
-    use futures_lite::prelude::*;
-
-    #[test]
-    fn smoke() {
-        crate::runtime::block_on(async {
-            let interval = Duration::from_millis(100);
-            let throttle = Duration::from_millis(300);
-
-            let take = 4;
-            let expected = 2;
-
-            let mut counter = 0;
-            crate::stream::interval(interval)
-                .take(take)
-                .throttle(throttle)
-                .for_each(|_| counter += 1)
-                .await;
-
-            assert_eq!(counter, expected);
-        })
-    }
-}