Searched defs:StreamController (Results 1 – 1 of 1) sorted by relevance
212 pub(crate) struct StreamController<S> { struct215 pub(crate) io_shutdown: AtomicBool,218 pub(crate) occupied: AtomicU32,219 pub(crate) dispatcher_invalid: AtomicBool,220 pub(crate) manager: AsyncMutex<IoManager<S>>,221 pub(crate) stream_waker: Mutex<StreamWaker>,299 impl<S> StreamController<S> { implementation