Struct Observable

pub struct Observable<P: Peer> { /* private fields */ }

Implementations

impl<P: Peer + 'static> Observable<P>

pub fn new(peer: P) -> Observable<P>

pub fn subscribe_peer_progress(&self) -> Receiver<Progress>

Trait Implementations

impl<P: Peer> Clone for Observable<P>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<P: Peer + 'static> Peer for Observable<P>

fn subscribe_veilid_update(&self) -> Receiver<VeilidUpdate>

async fn reset(&mut self) -> Result<()>

async fn shutdown(self) -> Result<()>

async fn announce( &mut self, index: &Index, ) -> Result<(CryptoTyped<CryptoKey>, Target, Header)>

async fn reannounce_route( &mut self, key: &CryptoTyped<CryptoKey>, prior_route: Option<Target>, index: &Index, header: &Header, ) -> Result<(Target, Header)>

async fn resolve( &mut self, key: &CryptoTyped<CryptoKey>, root: &Path, ) -> Result<(Target, Header, Index)>

async fn reresolve_route( &mut self, key: &CryptoTyped<CryptoKey>, prior_route: Option<Target>, ) -> Result<(Target, Header)>

async fn request_block( &mut self, target: Target, piece: usize, block: usize, ) -> Result<Vec<u8>>

async fn reply_block_contents( &mut self, call_id: OperationId, contents: &[u8], ) -> Result<()>