async fn chunks(&self) -> Result<Vec<Arc<dyn QueryChunk>>> {
            let pred = Predicate::default();

            self.querier_table
                .ingester_connection
                .as_any()
                .downcast_ref::<MockIngesterConnection>()
                .unwrap()
                .next_response(Ok(self.ingester_partitions.clone()));

            self.querier_table.chunks(&pred).await
        }
/// Invokes querier_table.chunks modeling the ingester sending the partitions in this table
Invokes querier_table.chunks modeling the ingester sending the partitions in this table
Invokes querier_table . chunks modeling the ingester sending the partitions in this table
async fn chunks(&self) -> Result<Vec<Arc<dyn QueryChunk>>> {
            let pred = Predicate::default();
            self.querier_table
                .ingester_connection
                .as_any()
                .downcast_ref::<MockIngesterConnection>()
                .unwrap()
                .next_response(Ok(self.ingester_partitions.clone()));
            self.querier_table.chunks(&pred).await
        }
async fn chunks ( & self ) -> Result < Vec < Arc < dyn QueryChunk > > > { let pred = Predicate :: default ( ) ; self . querier_table . ingester_connection . as_any ( ) . downcast_ref :: < MockIngesterConnection > ( ) . unwrap ( ) . next_response ( Ok ( self . ingester_partitions . clone ( ) ) ) ; self . querier_table . chunks ( & pred ) . await }
Invokes querier_table.chunks modeling the ingester sending the partitions in this table
Invokes querier_table . chunks modeling the ingester sending the partitions in this table
&self
&self