@@ -1228,14 +1228,6 @@ impl Queue {
12281228 Ok ( map)
12291229 }
12301230
1231- fn get_range (
1232- & self ,
1233- entity_type : & EntityType ,
1234- block_range : Range < BlockNumber > ,
1235- ) -> Result < BTreeMap < BlockNumber , Vec < Entity > > , StoreError > {
1236- self . store . get_range ( entity_type, block_range)
1237- }
1238-
12391231 fn get_derived (
12401232 & self ,
12411233 derived_query : & DerivedEntityQuery ,
@@ -1448,17 +1440,6 @@ impl Writer {
14481440 }
14491441 }
14501442
1451- fn get_range (
1452- & self ,
1453- entity_type : & EntityType ,
1454- block_range : Range < BlockNumber > ,
1455- ) -> Result < BTreeMap < BlockNumber , Vec < Entity > > , StoreError > {
1456- match self {
1457- Writer :: Sync ( store) => store. get_range ( entity_type, block_range) ,
1458- Writer :: Async { queue, .. } => queue. get_range ( entity_type, block_range) ,
1459- }
1460- }
1461-
14621443 fn get_derived (
14631444 & self ,
14641445 key : & DerivedEntityQuery ,
@@ -1587,12 +1568,14 @@ impl ReadStore for WritableStore {
15871568 self . writer . get_many ( keys)
15881569 }
15891570
1571+ // The entities that are returned are only the ones from the database.
1572+ // The ones in the queue are ignored.
15901573 fn get_range (
15911574 & self ,
15921575 entity_type : & EntityType ,
15931576 block_range : Range < BlockNumber > ,
15941577 ) -> Result < BTreeMap < BlockNumber , Vec < Entity > > , StoreError > {
1595- self . writer . get_range ( entity_type, block_range)
1578+ self . store . get_range ( entity_type, block_range)
15961579 }
15971580
15981581 fn get_derived (
0 commit comments