Struct QueryingSubscriberBuilder

pub struct QueryingSubscriberBuilder<'a, 'b, KeySpace, Handler, const BACKGROUND: bool = false> { /* private fields */ }

👎Deprecated: Use AdvancedPublisher and AdvancedSubscriber instead.

The builder of FetchingSubscriber, allowing to configure it.

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

Implementations

impl<'a, 'b, KeySpace> QueryingSubscriberBuilder<'a, 'b, KeySpace, DefaultHandler>

pub fn callback<F>( self, callback: F, ) -> QueryingSubscriberBuilder<'a, 'b, KeySpace, Callback<Sample>>

where F: Fn(Sample) + Send + Sync + 'static,

👎Deprecated: Use AdvancedPublisher and AdvancedSubscriber instead.

Add callback to FetchingSubscriber.

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

pub fn callback_mut<F>( self, callback: F, ) -> QueryingSubscriberBuilder<'a, 'b, KeySpace, Callback<Sample>>

where F: FnMut(Sample) + Send + Sync + 'static,

👎Deprecated: Use AdvancedPublisher and AdvancedSubscriber instead.

Add callback to FetchingSubscriber.

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

Using this guarantees that your callback will never be called concurrently. If your callback is also accepted by the callback method, we suggest you use it instead of callback_mut.

Subscriber will not be undeclared when dropped, with the callback running in background until the session is closed.

pub fn with<Handler>( self, handler: Handler, ) -> QueryingSubscriberBuilder<'a, 'b, KeySpace, Handler>

where Handler: IntoHandler<Sample>,

👎Deprecated: Use AdvancedPublisher and AdvancedSubscriber instead.

Use the given handler to receive Samples.

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

impl<'a, 'b, KeySpace> QueryingSubscriberBuilder<'a, 'b, KeySpace, Callback<Sample>>

pub fn background( self, ) -> QueryingSubscriberBuilder<'a, 'b, KeySpace, Callback<Sample>, true>

👎Deprecated: Use AdvancedPublisher and AdvancedSubscriber instead.

Register the subscriber callback to be run in background until the session is closed.

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

Background builder doesn’t return a FetchingSubscriber object anymore.

impl<'b, Handler, const BACKGROUND: bool> QueryingSubscriberBuilder<'_, 'b, UserSpace, Handler, BACKGROUND>

pub fn allowed_origin(self, origin: Locality) -> Self

👎Deprecated: Use AdvancedPublisher and AdvancedSubscriber instead.

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

Restrict the matching publications that will be receive by this Subscriber to the ones that have the given Locality.

pub fn query_selector<IntoSelector>(self, query_selector: IntoSelector) -> Self

where IntoSelector: TryInto<Selector<'b>>, <IntoSelector as TryInto<Selector<'b>>>::Error: Into<Error>,

👎Deprecated: Use AdvancedPublisher and AdvancedSubscriber instead.

Change the selector to be used for queries.

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

pub fn query_target(self, query_target: QueryTarget) -> Self

👎Deprecated: Use AdvancedPublisher and AdvancedSubscriber instead.

Change the target to be used for queries.

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

pub fn query_consolidation<QC: Into<QueryConsolidation>>( self, query_consolidation: QC, ) -> Self

👎Deprecated: Use AdvancedPublisher and AdvancedSubscriber instead.

Change the consolidation mode to be used for queries.

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

pub fn query_accept_replies(self, accept_replies: ReplyKeyExpr) -> Self

👎Deprecated: Use AdvancedPublisher and AdvancedSubscriber instead.

Change the accepted replies for queries.

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

impl<'a, 'b, KeySpace, Handler, const BACKGROUND: bool> QueryingSubscriberBuilder<'a, 'b, KeySpace, Handler, BACKGROUND>

pub fn query_timeout(self, query_timeout: Duration) -> Self

👎Deprecated: Use AdvancedPublisher and AdvancedSubscriber instead.

Change the timeout to be used for queries.

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

Trait Implementations

impl<KeySpace> IntoFuture for QueryingSubscriberBuilder<'_, '_, KeySpace, Callback<Sample>, true>

where KeySpace: Into<KeySpace> + Clone,

type Output = <QueryingSubscriberBuilder<'_, '_, KeySpace, Callback<Sample>, true> as Resolvable>::To

The output that the future will produce on completion.

type IntoFuture = Ready<<QueryingSubscriberBuilder<'_, '_, KeySpace, Callback<Sample>, true> as Resolvable>::To>

Which kind of future are we turning this into?

fn into_future(self) -> Self::IntoFuture

Creates a future from a value.

impl<KeySpace, Handler> IntoFuture for QueryingSubscriberBuilder<'_, '_, KeySpace, Handler>

where KeySpace: Into<KeySpace> + Clone, Handler: IntoHandler<Sample> + Send, Handler::Handler: Send,

type Output = <QueryingSubscriberBuilder<'_, '_, KeySpace, Handler> as Resolvable>::To

The output that the future will produce on completion.

type IntoFuture = Ready<<QueryingSubscriberBuilder<'_, '_, KeySpace, Handler> as Resolvable>::To>

Which kind of future are we turning this into?

fn into_future(self) -> Self::IntoFuture

Creates a future from a value.

impl<KeySpace> Resolvable for QueryingSubscriberBuilder<'_, '_, KeySpace, Callback<Sample>, true>

type To = Result<(), Box<dyn Error + Sync + Send>>

impl<KeySpace, Handler> Resolvable for QueryingSubscriberBuilder<'_, '_, KeySpace, Handler>

where Handler: IntoHandler<Sample>, Handler::Handler: Send,

type To = Result<FetchingSubscriber<<Handler as IntoHandler<Sample>>::Handler>, Box<dyn Error + Sync + Send>>

impl<KeySpace> Wait for QueryingSubscriberBuilder<'_, '_, KeySpace, Callback<Sample>, true>

where KeySpace: Into<KeySpace> + Clone,

fn wait(self) -> <Self as Resolvable>::To

Synchronously execute and wait

impl<KeySpace, Handler> Wait for QueryingSubscriberBuilder<'_, '_, KeySpace, Handler>

where KeySpace: Into<KeySpace> + Clone, Handler: IntoHandler<Sample> + Send, Handler::Handler: Send,

fn wait(self) -> <Self as Resolvable>::To

Synchronously execute and wait