Lines Matching refs:host_future_consumers

124     host_future_consumers: HashMap<u32, (HostFutureConsumerState, Weak<()>)>,  field
419                     let (mut state, _weak) = s.get().host_future_consumers.remove(&id).unwrap();  in future_or_stream_cmd()
473                     .host_future_consumers  in future_or_stream_cmd()
481                     s.host_future_consumers[&id],  in future_or_stream_cmd()
488                 let (state, _) = s.get().host_future_consumers.remove(&id).unwrap();  in future_or_stream_cmd()
498                 let (state, _) = s.get().host_future_consumers.get_mut(&id).unwrap();  in future_or_stream_cmd()
513             let (state, _) = s.get().host_future_consumers.get_mut(&id).unwrap();  in future_or_stream_cmd()
520                     s.host_future_consumers.get(&payload.future),  in future_or_stream_cmd()
528                     .host_future_consumers  in future_or_stream_cmd()
792             .host_future_consumers  in ensure_future_reading()
856         let state = match store.data_mut().host_future_consumers.get_mut(&self.0) {  in poll_consume()
881                     .host_future_consumers  in poll_consume()