Method poll

p2p/src/providers.rs:219–251

(&mut self, kad: &mut kad::Behaviour<MemoryStore>)

    }

    pub fn poll(&mut self, kad: &mut kad::Behaviour<MemoryStore>) {
        // Start a new query if not enough and have an outstanding one.
        if self.current_queries.len() < self.max_running_queries {
            if let Some(Query { key, queries }) = self.outstanding_queries.pop_front() {
                let query_id = kad.get_providers(key.clone());
                self.current_queries.insert(
                    key,
                    RunningQuery {
                        query_id,
                        found_providers: Default::default(),
                        queries,
                    },
                );
            }
        }

        // Cleanup
        for query in self.current_queries.values_mut() {
            query
                .queries
                .retain(|query| !query.response_channel.is_closed());
        }
        self.current_queries.retain(|_, query| {
            if query.queries.is_empty() {
                if let Some(mut query) = kad.query_mut(&query.query_id) {
                    query.finish();
                }
                false
            } else {
                true
            }
        });
    }
}