Skip to content

Commit 994f45d

Browse files
committed
fix merge artifact
1 parent fdea0e1 commit 994f45d

File tree

1 file changed

+3
-8
lines changed

1 file changed

+3
-8
lines changed

dash-spv-ffi/src/client.rs

Lines changed: 3 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -889,29 +889,24 @@ pub unsafe extern "C" fn dash_spv_ffi_client_sync_to_tip_with_progress(
889889
let (_command_sender, command_receiver) = tokio::sync::mpsc::unbounded_channel();
890890
let run_token = shutdown_token_sync.clone();
891891
let (abort_handle, abort_registration) = AbortHandle::new_pair();
892-
<<<<<<< HEAD
893-
let mut run_future = Box::pin(Abortable::new(
894-
spv_client.run(command_receiver, run_token),
895-
=======
896892
let mut monitor_future = Box::pin(Abortable::new(
897893
spv_client.monitor_network(command_receiver, run_token),
898-
>>>>>>> feat/dash-spv-client-interface
899894
abort_registration,
900895
));
901896
let result = tokio::select! {
902-
res = &mut run_future => match res {
897+
res = &mut monitor_future => match res {
903898
Ok(inner) => inner,
904899
Err(_) => Ok(()),
905900
},
906901
_ = shutdown_token_sync.cancelled() => {
907902
abort_handle.abort();
908-
match run_future.as_mut().await {
903+
match monitor_future.as_mut().await {
909904
Ok(inner) => inner,
910905
Err(_) => Ok(()),
911906
}
912907
}
913908
};
914-
drop(run_future);
909+
drop(monitor_future);
915910
let mut guard = inner.lock().unwrap();
916911
*guard = Some(spv_client);
917912
result

0 commit comments

Comments
 (0)