1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
//! Wait-for-text example: drive `Pane::wait_for_text` to react to
//! rendered pane content.
//!
//! Compile-tested by `cargo build --workspace --examples` and
//! `cargo clippy --workspace --all-targets --locked`. Running it requires a
//! reachable RMUX daemon; the call layout is the same whether the daemon
//! is local SDK discovery or a Unix socket configured by an integration
//! harness.
//!
//! The example uses only types re-exported from `rmux_sdk` and does not
//! depend on `rmux-client`, `rmux-core`, `rmux-server`, or `rmux-pty`.
use std::time::Duration;
use rmux_sdk::{EnsureSession, ProcessSpec, Result, Rmux, TerminalSizeSpec};
#[tokio::main]
async fn main() -> Result<()> {
let rmux = Rmux::builder()
.default_endpoint()
.default_timeout(Duration::from_secs(10))
.build();
// Bind to a known session via create-or-reuse semantics. The example
// launches a short shell pane that prints a sentinel banner so the
// wait_for_text call below has a deterministic match to land on.
let session = rmux
.ensure_session(
EnsureSession::try_named("rmux-sdk-wait-for-text")?
.create_or_reuse()
.size(TerminalSizeSpec::new(80, 24))
.process(ProcessSpec {
command: Some(vec![
"sh".to_owned(),
"-c".to_owned(),
"printf 'ready\\n'; sleep 5".to_owned(),
]),
environment: None,
}),
)
.await?;
let pane = session.pane(0, 0);
// Poll the rendered visible-text grid until the sentinel appears.
// `wait_for_text` is client-side: it captures snapshots and runs them
// through the same `PaneSnapshot::find_text` helper a caller could
// invoke directly, so the wait observes whatever the pane has already
// rendered when it starts.
pane.wait_for_text("ready").await?;
// Re-capture once the wait succeeds to inspect the matched coordinate.
let snapshot = pane.snapshot().await?;
if let Some(hit) = snapshot.find_text("ready") {
println!(
"wait_for_text matched 'ready' at row {} col {}",
hit.start_row, hit.start_col,
);
}
Ok(())
}