Searched defs:OpaqueStreamRef (Results 1 – 1 of 1) sorted by relevance
59 pub(crate) struct OpaqueStreamRef { struct60 inner: Arc<Mutex<Inner>>,61 key: store::Key,222 pending: Option<&OpaqueStreamRef>, in send_request()949 pending: Option<&OpaqueStreamRef>, in poll_pending_open()1264 pub fn clone_to_opaque(&self) -> OpaqueStreamRef { in clone_to_opaque()1284 impl OpaqueStreamRef { implementation1285 fn new(inner: Arc<Mutex<Inner>>, stream: &mut store::Ptr) -> OpaqueStreamRef { in new()1305 ) -> Poll<Option<Result<(Request<()>, OpaqueStreamRef), proto::Error>>> { in poll_pushed() argument1392 impl fmt::Debug for OpaqueStreamRef { implementation[all …]