@@ -238,7 +238,7 @@ mod tests {
238
238
239
239
#[ tokio:: test]
240
240
async fn sync_from_same_chain ( ) {
241
- let mut chain = Blockchain :: default ( ) . with_height ( 4 ) ;
241
+ let chain = Blockchain :: default ( ) . with_height ( 4 ) ;
242
242
243
243
let listener_1 = MockChainListener :: new ( )
244
244
. expect_block_connected ( * chain. at_height ( 2 ) )
@@ -256,15 +256,15 @@ mod tests {
256
256
( chain. at_height( 3 ) . block_hash, & listener_3 as & dyn chain:: Listen ) ,
257
257
] ;
258
258
let mut cache = chain. header_cache ( 0 ..=4 ) ;
259
- match synchronize_listeners ( & mut chain, Network :: Bitcoin , & mut cache, listeners) . await {
259
+ match synchronize_listeners ( & chain, Network :: Bitcoin , & mut cache, listeners) . await {
260
260
Ok ( header) => assert_eq ! ( header, chain. tip( ) ) ,
261
261
Err ( e) => panic ! ( "Unexpected error: {:?}" , e) ,
262
262
}
263
263
}
264
264
265
265
#[ tokio:: test]
266
266
async fn sync_from_different_chains ( ) {
267
- let mut main_chain = Blockchain :: default ( ) . with_height ( 4 ) ;
267
+ let main_chain = Blockchain :: default ( ) . with_height ( 4 ) ;
268
268
let fork_chain_1 = main_chain. fork_at_height ( 1 ) ;
269
269
let fork_chain_2 = main_chain. fork_at_height ( 2 ) ;
270
270
let fork_chain_3 = main_chain. fork_at_height ( 3 ) ;
@@ -293,15 +293,15 @@ mod tests {
293
293
let mut cache = fork_chain_1. header_cache ( 2 ..=4 ) ;
294
294
cache. extend ( fork_chain_2. header_cache ( 3 ..=4 ) ) ;
295
295
cache. extend ( fork_chain_3. header_cache ( 4 ..=4 ) ) ;
296
- match synchronize_listeners ( & mut main_chain, Network :: Bitcoin , & mut cache, listeners) . await {
296
+ match synchronize_listeners ( & main_chain, Network :: Bitcoin , & mut cache, listeners) . await {
297
297
Ok ( header) => assert_eq ! ( header, main_chain. tip( ) ) ,
298
298
Err ( e) => panic ! ( "Unexpected error: {:?}" , e) ,
299
299
}
300
300
}
301
301
302
302
#[ tokio:: test]
303
303
async fn sync_from_overlapping_chains ( ) {
304
- let mut main_chain = Blockchain :: default ( ) . with_height ( 4 ) ;
304
+ let main_chain = Blockchain :: default ( ) . with_height ( 4 ) ;
305
305
let fork_chain_1 = main_chain. fork_at_height ( 1 ) ;
306
306
let fork_chain_2 = fork_chain_1. fork_at_height ( 2 ) ;
307
307
let fork_chain_3 = fork_chain_2. fork_at_height ( 3 ) ;
@@ -336,15 +336,15 @@ mod tests {
336
336
let mut cache = fork_chain_1. header_cache ( 2 ..=4 ) ;
337
337
cache. extend ( fork_chain_2. header_cache ( 3 ..=4 ) ) ;
338
338
cache. extend ( fork_chain_3. header_cache ( 4 ..=4 ) ) ;
339
- match synchronize_listeners ( & mut main_chain, Network :: Bitcoin , & mut cache, listeners) . await {
339
+ match synchronize_listeners ( & main_chain, Network :: Bitcoin , & mut cache, listeners) . await {
340
340
Ok ( header) => assert_eq ! ( header, main_chain. tip( ) ) ,
341
341
Err ( e) => panic ! ( "Unexpected error: {:?}" , e) ,
342
342
}
343
343
}
344
344
345
345
#[ tokio:: test]
346
346
async fn cache_connected_and_keep_disconnected_blocks ( ) {
347
- let mut main_chain = Blockchain :: default ( ) . with_height ( 2 ) ;
347
+ let main_chain = Blockchain :: default ( ) . with_height ( 2 ) ;
348
348
let fork_chain = main_chain. fork_at_height ( 1 ) ;
349
349
let new_tip = main_chain. tip ( ) ;
350
350
let old_tip = fork_chain. tip ( ) ;
@@ -355,7 +355,7 @@ mod tests {
355
355
356
356
let listeners = vec ! [ ( old_tip. block_hash, & listener as & dyn chain:: Listen ) ] ;
357
357
let mut cache = fork_chain. header_cache ( 2 ..=2 ) ;
358
- match synchronize_listeners ( & mut main_chain, Network :: Bitcoin , & mut cache, listeners) . await {
358
+ match synchronize_listeners ( & main_chain, Network :: Bitcoin , & mut cache, listeners) . await {
359
359
Ok ( _) => {
360
360
assert ! ( cache. contains_key( & new_tip. block_hash) ) ;
361
361
assert ! ( cache. contains_key( & old_tip. block_hash) ) ;
0 commit comments