zenoh_ext

Trait AdvancedSubscriberBuilderExt

Source 
pub trait AdvancedSubscriberBuilderExt<'a, 'b, 'c, Handler> {
    // Required methods
    fn history(
        self,
        config: HistoryConfig,
    ) -> AdvancedSubscriberBuilder<'a, 'b, 'c, Handler>;
    fn recovery(
        self,
        conf: RecoveryConfig<Configured>,
    ) -> AdvancedSubscriberBuilder<'a, 'b, 'c, Handler>;
    fn subscriber_detection(
        self,
    ) -> AdvancedSubscriberBuilder<'a, 'b, 'c, Handler>;
    fn advanced(self) -> AdvancedSubscriberBuilder<'a, 'b, 'c, Handler>;
}
Expand description

Some extensions to the zenoh::subscriber::SubscriberBuilder

This API has been marked as unstable: it works as advertised, but it may be changed in a future release.

Required Methods§

Source

fn history( self, config: HistoryConfig, ) -> AdvancedSubscriberBuilder<'a, 'b, 'c, Handler>

Enable query for historical data.

This API has been marked as unstable: it works as advertised, but it may be changed in a future release.

History can only be retransmitted by AdvancedPublishers that enable cache.

Source

fn recovery( self, conf: RecoveryConfig<Configured>, ) -> AdvancedSubscriberBuilder<'a, 'b, 'c, Handler>

Ask for retransmission of detected lost Samples.

This API has been marked as unstable: it works as advertised, but it may be changed in a future release.

Retransmission can only be achieved by AdvancedPublishers that enable cache and sample_miss_detection.

Source

fn subscriber_detection(self) -> AdvancedSubscriberBuilder<'a, 'b, 'c, Handler>

Allow this subscriber to be detected through liveliness.

This API has been marked as unstable: it works as advertised, but it may be changed in a future release.
Source

fn advanced(self) -> AdvancedSubscriberBuilder<'a, 'b, 'c, Handler>

Turn this Subscriberinto an AdvancedSubscriber.

This API has been marked as unstable: it works as advertised, but it may be changed in a future release.

Implementations on Foreign Types§

Source§

impl<'a, 'b, 'c, Handler> AdvancedSubscriberBuilderExt<'a, 'b, 'c, Handler> for SubscriberBuilder<'a, 'b, Handler>

Source§

fn history( self, config: HistoryConfig, ) -> AdvancedSubscriberBuilder<'a, 'b, 'c, Handler>

Enable query for historical data.

This API has been marked as unstable: it works as advertised, but it may be changed in a future release.

History can only be retransmitted by AdvancedPublishers that enable cache.

Source§

fn recovery( self, conf: RecoveryConfig<Configured>, ) -> AdvancedSubscriberBuilder<'a, 'b, 'c, Handler>

Ask for retransmission of detected lost Samples.

This API has been marked as unstable: it works as advertised, but it may be changed in a future release.

Retransmission can only be achieved by AdvancedPublishers that enable cache and sample_miss_detection.

Source§

fn subscriber_detection(self) -> AdvancedSubscriberBuilder<'a, 'b, 'c, Handler>

Allow this subscriber to be detected through liveliness.

This API has been marked as unstable: it works as advertised, but it may be changed in a future release.
Source§

fn advanced(self) -> AdvancedSubscriberBuilder<'a, 'b, 'c, Handler>

Turn this Subscriberinto an AdvancedSubscriber.

This API has been marked as unstable: it works as advertised, but it may be changed in a future release.

Implementors§