Trait zenoh_protocol::session::Primitives[−][src]

pub trait Primitives {
#[must_use]    fn resource<'life0, 'life1, 'async_trait>(
        &'life0 self, 
        rid: ZInt, 
        reskey: &'life1 ResKey
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        'life1: 'async_trait,
        Self: 'async_trait;

#[must_use]    fn forget_resource<'life0, 'async_trait>(
        &'life0 self, 
        rid: ZInt
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;

#[must_use]    fn publisher<'life0, 'life1, 'async_trait>(
        &'life0 self, 
        reskey: &'life1 ResKey
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        'life1: 'async_trait,
        Self: 'async_trait;

#[must_use]    fn forget_publisher<'life0, 'life1, 'async_trait>(
        &'life0 self, 
        reskey: &'life1 ResKey
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        'life1: 'async_trait,
        Self: 'async_trait;

#[must_use]    fn subscriber<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self, 
        reskey: &'life1 ResKey, 
        sub_info: &'life2 SubInfo
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        'life1: 'async_trait,
        'life2: 'async_trait,
        Self: 'async_trait;

#[must_use]    fn forget_subscriber<'life0, 'life1, 'async_trait>(
        &'life0 self, 
        reskey: &'life1 ResKey
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        'life1: 'async_trait,
        Self: 'async_trait;

#[must_use]    fn queryable<'life0, 'life1, 'async_trait>(
        &'life0 self, 
        reskey: &'life1 ResKey
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        'life1: 'async_trait,
        Self: 'async_trait;

#[must_use]    fn forget_queryable<'life0, 'life1, 'async_trait>(
        &'life0 self, 
        reskey: &'life1 ResKey
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        'life1: 'async_trait,
        Self: 'async_trait;

#[must_use]    fn data<'life0, 'life1, 'async_trait>(
        &'life0 self, 
        reskey: &'life1 ResKey, 
        payload: RBuf, 
        reliability: Reliability, 
        congestion_control: CongestionControl, 
        data_info: Option<DataInfo>
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        'life1: 'async_trait,
        Self: 'async_trait;

#[must_use]    fn query<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self, 
        reskey: &'life1 ResKey, 
        predicate: &'life2 str, 
        qid: ZInt, 
        target: QueryTarget, 
        consolidation: QueryConsolidation
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        'life1: 'async_trait,
        'life2: 'async_trait,
        Self: 'async_trait;

#[must_use]    fn reply_data<'life0, 'async_trait>(
        &'life0 self, 
        qid: ZInt, 
        source_kind: ZInt, 
        replier_id: PeerId, 
        reskey: ResKey, 
        info: Option<DataInfo>, 
        payload: RBuf
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;

#[must_use]    fn reply_final<'life0, 'async_trait>(
        &'life0 self, 
        qid: ZInt
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;

#[must_use]    fn pull<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self, 
        is_final: bool, 
        reskey: &'life1 ResKey, 
        pull_id: ZInt, 
        max_samples: &'life2 Option<ZInt>
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        'life1: 'async_trait,
        'life2: 'async_trait,
        Self: 'async_trait;

#[must_use]    fn close<'life0, 'async_trait>(
        &'life0 self
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;
}

Required methods

#[must_use]fn resource<'life0, 'life1, 'async_trait>(
    &'life0 self,
    rid: ZInt,
    reskey: &'life1 ResKey
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, [src]

#[must_use]fn forget_resource<'life0, 'async_trait>(
    &'life0 self,
    rid: ZInt
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, [src]

#[must_use]fn publisher<'life0, 'life1, 'async_trait>(
    &'life0 self,
    reskey: &'life1 ResKey
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, [src]

#[must_use]fn forget_publisher<'life0, 'life1, 'async_trait>(
    &'life0 self,
    reskey: &'life1 ResKey
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, [src]

#[must_use]fn subscriber<'life0, 'life1, 'life2, 'async_trait>(
    &'life0 self,
    reskey: &'life1 ResKey,
    sub_info: &'life2 SubInfo
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    'life2: 'async_trait,
    Self: 'async_trait, [src]

#[must_use]fn forget_subscriber<'life0, 'life1, 'async_trait>(
    &'life0 self,
    reskey: &'life1 ResKey
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, [src]

#[must_use]fn queryable<'life0, 'life1, 'async_trait>(
    &'life0 self,
    reskey: &'life1 ResKey
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, [src]

#[must_use]fn forget_queryable<'life0, 'life1, 'async_trait>(
    &'life0 self,
    reskey: &'life1 ResKey
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, [src]

#[must_use]fn data<'life0, 'life1, 'async_trait>(
    &'life0 self,
    reskey: &'life1 ResKey,
    payload: RBuf,
    reliability: Reliability,
    congestion_control: CongestionControl,
    data_info: Option<DataInfo>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, [src]

#[must_use]fn query<'life0, 'life1, 'life2, 'async_trait>(
    &'life0 self,
    reskey: &'life1 ResKey,
    predicate: &'life2 str,
    qid: ZInt,
    target: QueryTarget,
    consolidation: QueryConsolidation
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    'life2: 'async_trait,
    Self: 'async_trait, [src]

#[must_use]fn reply_data<'life0, 'async_trait>(
    &'life0 self,
    qid: ZInt,
    source_kind: ZInt,
    replier_id: PeerId,
    reskey: ResKey,
    info: Option<DataInfo>,
    payload: RBuf
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, [src]

#[must_use]fn reply_final<'life0, 'async_trait>(
    &'life0 self,
    qid: ZInt
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, [src]

#[must_use]fn pull<'life0, 'life1, 'life2, 'async_trait>(
    &'life0 self,
    is_final: bool,
    reskey: &'life1 ResKey,
    pull_id: ZInt,
    max_samples: &'life2 Option<ZInt>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    'life2: 'async_trait,
    Self: 'async_trait, [src]

#[must_use]fn close<'life0, 'async_trait>(
    &'life0 self
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, [src]

Loading content...

Implementors

impl<T: SessionEventHandler + Send + Sync + ?Sized> Primitives for Mux<T>[src]

Loading content...