2 use super::{Event, GlobalErrorContextRefCount, Waitable, WaitableCommon};
2371                         TransmitIndex::Future(ty) => Event::FutureWrite {  in host_drop_reader()
2375                         TransmitIndex::Stream(ty) => Event::StreamWrite {  in host_drop_reader()
2389                         TransmitKind::Future => Event::FutureWrite {  in host_drop_reader()
2393                         TransmitKind::Stream => Event::StreamWrite {  in host_drop_reader()
2470                         TransmitIndex::Future(ty) => Event::FutureRead {  in host_drop_writer()
2474                         TransmitIndex::Stream(ty) => Event::StreamRead {  in host_drop_writer()
2489                         Some(_) => Event::FutureRead {  in host_drop_writer()
2493                         None => Event::StreamRead {  in host_drop_writer()
3535                     let total = if let Some(Event::StreamRead {  in guest_write()
3762                     let total = if let Some(Event::StreamWrite {  in guest_read()
3870         if let Some(event @ (Event::StreamWrite { code, .. } | Event::FutureWrite { code, .. })) =  in wait_for_write()
3897             let (Event::FutureWrite { code, .. } | Event::StreamWrite { code, .. }) = event else {  in cancel_write()
3902                 (ReturnCode::Completed(count), Event::StreamWrite { .. }) => {  in cancel_write()
3957         if let Some(event @ (Event::StreamRead { code, .. } | Event::FutureRead { code, .. })) =  in wait_for_read()
3984             let (Event::FutureRead { code, .. } | Event::StreamRead { code, .. }) = event else {  in cancel_read()
3989                 (ReturnCode::Completed(count), Event::StreamRead { .. }) => {  in cancel_read()
4519                 TransmitIndex::Future(ty) => Event::FutureWrite {  in send_write_result()
4523                 TransmitIndex::Stream(ty) => Event::StreamWrite {  in send_write_result()
4542                 TransmitIndex::Future(ty) => Event::FutureRead {  in send_read_result()
4546                 TransmitIndex::Stream(ty) => Event::StreamRead {  in send_read_result()
4554     fn take_event(&mut self, waitable: u32) -> Result<Option<Event>> {  in take_event()  argument
4558     fn set_event(&mut self, waitable: u32, event: Event) -> Result<()> {  in set_event()
4572     fn update_event(&mut self, waitable: u32, event: Event) -> Result<()> {  in update_event()
4592             (Some(old @ Event::FutureWrite { .. }), Event::FutureWrite { .. }) => old,  in update_event()
4593             (Some(old @ Event::FutureRead { .. }), Event::FutureRead { .. }) => old,  in update_event()
4595                 Some(Event::StreamWrite {  in update_event()
4599                 Event::StreamWrite { code, pending },  in update_event()
4600             ) => Event::StreamWrite {  in update_event()
4605                 Some(Event::StreamRead {  in update_event()
4609                 Event::StreamRead { code, pending },  in update_event()
4610             ) => Event::StreamRead {  in update_event()
4668         event: Event,  in on_delivery()  argument
4672             Event::FutureRead {  in on_delivery()
4676             | Event::FutureWrite {  in on_delivery()
4686             Event::StreamRead {  in on_delivery()
4690             | Event::StreamWrite {  in on_delivery()
4710             Event::FutureRead { .. } | Event::StreamRead { .. } => {  in on_delivery()
4713             Event::FutureWrite { .. } | Event::StreamWrite { .. } => {  in on_delivery()
4725             Event::StreamRead { .. } => {  in on_delivery()
4728             Event::StreamWrite { .. } => transmit.write = WriteState::Open,  in on_delivery()