docs(irtt-client): document caller-owned cadence

crates/irtt-client/src/async_client/tests.rs

@@ -590,11 +590,8 @@ fn blocking_and_async_roll_back_a_failed_open_and_accept_a_retry() {
     // must be able to open the same connected client.
     let blocking_server = start_silent_then_open_server(1);
     let mut blocking = Client::connect(config(blocking_server.addr, None, 0)).unwrap();
-    assert!(!blocking.has_pending_probes());
     let blocking_first = blocking.open().unwrap_err();
-    assert!(!blocking.has_pending_probes());
     let blocking_second = blocking.open().unwrap();
-    assert!(!blocking.has_pending_probes());
     let blocking_sent = blocking.send_probe().unwrap();
     let blocking_reply = blocking.recv_once().unwrap();
     let blocking_close = blocking.close().unwrap();
@@ -606,11 +603,8 @@ fn blocking_and_async_roll_back_a_failed_open_and_accept_a_retry() {
             let mut client = AsyncClient::connect(config(async_server.addr, None, 0))
                 .await
                 .unwrap();
-            assert!(!client.has_pending_probes());
             let first = client.open().await.unwrap_err();
-            assert!(!client.has_pending_probes());
             let second = client.open().await.unwrap();
-            assert!(!client.has_pending_probes());
             let sent = client.send_probe().await.unwrap();
             let reply = client.recv().await.unwrap();
             let closed = client.close().await.unwrap();

crates/irtt-client/src/session/machine.rs

@@ -560,7 +560,8 @@ impl SessionMachine {
     pub(crate) fn pending_is_empty(&self) -> bool {
         match &self.state {
             MachineState::Open(session) => session.pending.len() == 0,
-            _ => true,
+            MachineState::NoTestCompleted | MachineState::Closed { .. } => true,
+            MachineState::Connected => false,
         }
     }