[−][src]Function primal_crossbeam::primes_unbounded
pub fn primes_unbounded() -> (impl FnOnce() + Send, Receiver<usize>)
let (thread, r) = thread_spawn(primes_unbounded()); assert_eq!(r.recv(), Ok(2)); assert_eq!(r.recv(), Ok(3)); assert_eq!(r.recv(), Ok(5)); // thread.join(); // Would block indefinitely drop(r); thread.join();