Function nyx::iter::send

pub fn send<I, T>(
    iter: impl IntoIterator<Item = T, IntoIter = I>, 
    sender: Sender<Bps>
) -> Map<I, impl FnMut(T) -> T> where
    I: Iterator<Item = T>, 

Creates an iterator that yields the bytes by sending it through the provided Sender.

Examples

use std::sync::mpsc;
use std::thread;
use std::iter;

fn main() {
    let (sender, receiver) = mpsc::channel();
    thread::spawn(move || {
        nyx::iter::send(iter::repeat(0), sender).for_each(|_| ());
    });
    receiver
        .iter()
        .for_each(|bps| println!("From thread: {}", bps));
}