Struct ThreadRef 

pub struct ThreadRef { /* private fields */ }

Public, shared handle on a Thread. Implements Callable so a thread can be embedded as a workflow step or team child.

Implementations

impl ThreadRef

pub fn from_arc(inner: Arc<RwLock<Thread>>) -> Self

pub fn new(thread: Thread) -> Self

pub fn read(&self) -> RwLockReadGuard<'_, Thread>

pub fn write(&self) -> RwLockWriteGuard<'_, Thread>

pub fn id(&self) -> ThreadId

pub fn snapshot(&self) -> Thread

pub fn synthetic_inbound(&self, text: String) -> InboundMessage

Synthesize an inbound from a free-text string for ad-hoc callers (mainly the Callable impl). Provider-driven inbound goes through the orchestrator instead.

Trait Implementations

impl Callable for ThreadRef

Callable adapter — lets a thread be embedded anywhere a Callable is expected.

For ThreadTarget::Callable targets, we forward {"user": text, …} envelopes that AgentRef::call already understands. For ThreadTarget::Harness targets we call the wrapped callable (which is HarnessRef); see crate::ThreadTarget.

fn call<'life0, 'async_trait>( &'life0 self, input: Value, ctx: CallCtx, ) -> Pin<Box<dyn Future<Output = Result<Value>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn label(&self) -> &str

Human-readable label for telemetry. Default falls back to the type name.

impl Clone for ThreadRef

fn clone(&self) -> ThreadRef

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.