basis 0.8.2

The basis SDK: workspace discovery, run lifecycle, one event stream, and the two seams. No protocol, no transport, no TTY.
Documentation 
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

//! Lifetime guard for one lossless session observer.

use crate::workspace::lifecycle::ReuseLease;

/// Keeps one [`PreparedRun`](super::PreparedRun) agent-event tap registered.
///
/// Dropping this value waits for any callback already in flight, then prevents
/// every future invocation. Keep it alive for at least as long as the work
/// being observed; do not drop it while holding a resource the callback needs.
///
/// This is a Basis-owned opaque wrapper rather than Mentra's raw guard. That
/// keeps the public run contract stable while the private registration can
/// also retain a run-lifecycle lease when pooled runtimes arrive.
#[must_use = "dropping the guard unregisters the tap and may wait for an in-flight callback"]
pub struct AgentEventTapGuard {
    _registration: ObserverRegistration,
}

struct ObserverRegistration {
    // Fields drop in declaration order: unregister the callback before a
    // future lifecycle lease is released.
    _tap: mentra::agent::AgentEventTapGuard,
    _lifecycle_lease: Option<ReuseLease>,
}

impl AgentEventTapGuard {
    pub(super) fn new(
        tap: mentra::agent::AgentEventTapGuard,
        lifecycle_lease: Option<ReuseLease>,
    ) -> Self {
        Self {
            _registration: ObserverRegistration {
                _tap: tap,
                _lifecycle_lease: lifecycle_lease,
            },
        }
    }
}