Struct Thread 

pub struct Thread<'a, T: RpcTransport<Error = Error>> {
    pub reference: ThreadRef,
    /* private fields */
}

Fields

reference: ThreadRef

Implementations

impl<T: RpcTransport<Error = Error>> Thread<'_, T>

pub async fn publish_source( &self, source: &SourcePack, originals: &PublicationOriginals, options: PublicationOptions, ) -> Result<PublicationReceipt, Error>

One exchange, directly to this Thread’s endpoint. The source capture must carry its complete original proofs. Preparation and binding are local; no head lookup, proxy call or implicit capture happens here.

pub fn prepare_publication( &self, source: &SourcePack, originals: PublicationOriginals, options: PublicationOptions, spool_genesis: ContentHash, ) -> Result<PreparedPublication, Error>

Local preparation over exact source/originals; no network authorization or implicit acceptance. Call sign_acceptance explicitly, then send_prepared.

pub async fn send_prepared( &self, source: &SourcePack, prepared: &PreparedPublication, ) -> Result<PublicationReceipt, Error>

impl<T: RpcTransport<Error = Error>> Thread<'_, T>

pub async fn revise_intent( &self, command: &PreparedControl, ) -> Result<ThreadMutationResponse, ClientError<Error>>

Send a locally prepared original signed intent. Preparation consumes the existing overview’s field frontier and performs no extra RPC.

pub async fn observe( &self, sections: &[ThreadSection], mode: ObservationMode, resume: Option<Resume>, ) -> Result<ThreadObservation<T::Reader>, Error>