diff --git a/crates/core/tests/test_spk_client.rs b/crates/core/tests/test_spk_client.rs
index 38766ac31d..e65a3c63ab 100644
--- a/crates/core/tests/test_spk_client.rs
+++ b/crates/core/tests/test_spk_client.rs
@@ -1,4 +1,6 @@
-use bdk_core::spk_client::{FullScanResponse, SyncResponse};
+use bdk_core::spk_client::{FullScanResponse, SyncItem, SyncRequest, SyncResponse};
+use bitcoin::{hashes::Hash, OutPoint, ScriptBuf, Txid};
+use std::sync::{Arc, Mutex};
 
 #[test]
 fn test_empty() {
@@ -11,3 +13,72 @@ fn test_empty() {
         "Default `SyncResponse` must be empty"
     );
 }
+
+#[test]
+fn sync_request_reports_progress_to_inspect() {
+    let spk = ScriptBuf::from_bytes(vec![0x51]);
+    let txid = txid_from_byte(1);
+    let outpoint = OutPoint::new(txid_from_byte(2), 3);
+    let inspected = Arc::new(Mutex::new(Vec::new()));
+
+    let mut request = SyncRequest::builder_at(0)
+        .spks([spk.clone()])
+        .txids([txid])
+        .outpoints([outpoint])
+        .inspect({
+            let inspected = Arc::clone(&inspected);
+            move |item, p| {
+                let kind = match item {
+                    SyncItem::Spk(..) => "spk",
+                    SyncItem::Txid(_) => "txid",
+                    SyncItem::OutPoint(_) => "outpoint",
+                };
+                inspected.lock().unwrap().push((
+                    kind,
+                    p.spks_consumed,
+                    p.txids_consumed,
+                    p.outpoints_consumed,
+                ));
+            }
+        })
+        .build();
+
+    assert_eq!(
+        request.next_spk_with_expected_txids().map(|s| s.spk),
+        Some(spk)
+    );
+    assert_eq!(request.next_txid(), Some(txid));
+    assert_eq!(request.next_outpoint(), Some(outpoint));
+
+    // `inspect` sees progress *after* the item is consumed.
+    assert_eq!(
+        *inspected.lock().unwrap(),
+        [("spk", 1, 0, 0), ("txid", 1, 1, 0), ("outpoint", 1, 1, 1),]
+    );
+}
+
+#[test]
+fn sync_request_returns_expected_txids_for_matching_spk() {
+    let spk = ScriptBuf::from_bytes(vec![0x51]);
+    let other_spk = ScriptBuf::from_bytes(vec![0x52]);
+    let txid_a = txid_from_byte(42);
+    let txid_b = txid_from_byte(43);
+
+    let mut request = SyncRequest::builder_at(0)
+        .spks([spk.clone(), other_spk.clone()])
+        .expected_spk_txids([(spk.clone(), txid_a)])
+        .expected_spk_txids([(spk.clone(), txid_b)])
+        .build();
+
+    let first = request.next_spk_with_expected_txids().unwrap();
+    assert_eq!(first.spk, spk);
+    assert_eq!(first.expected_txids, [txid_a, txid_b].into());
+
+    let second = request.next_spk_with_expected_txids().unwrap();
+    assert_eq!(second.spk, other_spk);
+    assert!(second.expected_txids.is_empty());
+}
+
+fn txid_from_byte(byte: u8) -> Txid {
+    Txid::from_byte_array([byte; 32])
+}