Lines Matching refs:reader

1522     reader: Option<FutureReader<T>>,  field
1537 pub fn new(accessor: A, reader: FutureReader<T>) -> Self { in new()
1544 reader: Some(reader), in new()
1561 guard.reader.take().unwrap() in from()
1570 if let Some(reader) = &mut self.reader { in drop()
1573 let result = reader.close_with(&self.accessor); in drop()
1899 reader: Option<StreamReader<T>>, field
1915 pub fn new(accessor: A, reader: StreamReader<T>) -> Self { in new()
1922 reader: Some(reader), in new()
1939 guard.reader.take().unwrap() in from()
1948 if let Some(reader) = &mut self.reader { in drop()
1951 let result = reader.close_with(&self.accessor); in drop()
2895 let reader = transmit.read_handle; in set_consumer() localVariable
2896 self.0.host_drop_reader(reader, kind)?; in set_consumer()
4085 reader: u32, in guest_cancel_read()
4095 get_mut_by_index_from(self.id().get_mut(store).table_for_transmit(ty), ty, reader)?; in guest_cancel_read()
4111 get_mut_by_index_from(self.id().get_mut(store).table_for_transmit(ty), ty, reader)? in guest_cancel_read()
4125 reader: u32, in guest_drop_readable()
4129 TransmitIndex::Stream(ty) => table.stream_remove_readable(ty, reader)?, in guest_drop_readable()
4130 TransmitIndex::Future(ty) => table.future_remove_readable(ty, reader)?, in guest_drop_readable()
4232 reader: u32, in future_cancel_read()
4234 self.guest_cancel_read(store, TransmitIndex::Future(ty), async_, reader) in future_cancel_read()
4256 reader: u32, in stream_cancel_read()
4258 self.guest_cancel_read(store, TransmitIndex::Stream(ty), async_, reader) in stream_cancel_read()
4279 reader: u32, in future_drop_readable()
4281 self.guest_drop_readable(store, TransmitIndex::Future(ty), reader) in future_drop_readable()
4289 reader: u32, in stream_drop_readable()
4291 self.guest_drop_readable(store, TransmitIndex::Stream(ty), reader) in stream_drop_readable()