Lines Matching refs:OpaqueStreamRef
43 opaque: OpaqueStreamRef,
48 pub(crate) struct OpaqueStreamRef { struct
572 opaque: OpaqueStreamRef::new(self.inner.clone(), stream), in next_incoming()
663 pending: Option<&OpaqueStreamRef>, in send_request() argument
741 opaque: OpaqueStreamRef::new(self.inner.clone(), &mut stream), in send_request()
781 pending: Option<&OpaqueStreamRef>, in poll_pending_open() argument
1010 OpaqueStreamRef::new(self.opaque.inner.clone(), &mut me.store.resolve(child_key)); in send_push_promise()
1088 pub fn clone_to_opaque(&self) -> OpaqueStreamRef in clone_to_opaque()
1111 impl OpaqueStreamRef { impl
1112 fn new(inner: Arc<Mutex<Inner>>, stream: &mut store::Ptr) -> OpaqueStreamRef { in new() argument
1114 OpaqueStreamRef { in new()
1132 ) -> Poll<Option<Result<(Request<()>, OpaqueStreamRef), proto::Error>>> { in poll_pushed() argument
1143 OpaqueStreamRef::new(self.inner.clone(), &mut me.store.resolve(key)); in poll_pushed()
1218 impl fmt::Debug for OpaqueStreamRef { implementation
1242 impl Clone for OpaqueStreamRef { implementation
1249 OpaqueStreamRef { in clone()
1256 impl Drop for OpaqueStreamRef { implementation