Function ocl_stream::executor::stream::unbounded

pub fn unbounded<T>() -> (OCLStream<T>, OCLStreamSender<T>) where
    T: Send + Sync, 

Creates a new OCLStream with the corresponding sender to communicate between the scheduler thread and the receiver thread