Struct FetchingSubscriberBuilder

pub struct FetchingSubscriberBuilder<'a, 'b, KeySpace, Handler, Fetch: FnOnce(Box<dyn Fn(TryIntoSample) + Send + Sync>) -> Result<()>, TryIntoSample, const BACKGROUND: bool = false>
where
    TryIntoSample: ExtractSample,
{ /* 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, Fetch: FnOnce(Box<dyn Fn(TryIntoSample) + Send + Sync>) -> Result<()>, TryIntoSample> FetchingSubscriberBuilder<'a, 'b, KeySpace, DefaultHandler, Fetch, TryIntoSample>

where TryIntoSample: ExtractSample,

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

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, ) -> FetchingSubscriberBuilder<'a, 'b, KeySpace, Callback<Sample>, Fetch, TryIntoSample>

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, ) -> FetchingSubscriberBuilder<'a, 'b, KeySpace, Handler, Fetch, TryIntoSample>

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, Fetch: FnOnce(Box<dyn Fn(TryIntoSample) + Send + Sync>) -> Result<()>, TryIntoSample> FetchingSubscriberBuilder<'a, 'b, KeySpace, Callback<Sample>, Fetch, TryIntoSample>

where TryIntoSample: ExtractSample,

pub fn background( self, ) -> FetchingSubscriberBuilder<'a, 'b, KeySpace, Callback<Sample>, Fetch, TryIntoSample, 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<Handler, Fetch: FnOnce(Box<dyn Fn(TryIntoSample) + Send + Sync>) -> Result<()>, TryIntoSample, const BACKGROUND: bool> FetchingSubscriberBuilder<'_, '_, UserSpace, Handler, Fetch, TryIntoSample, BACKGROUND>

where TryIntoSample: ExtractSample,

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

👎Deprecated: Use AdvancedPublisher and AdvancedSubscriber instead.

Restrict the matching publications that will be received by this FetchingSubscriber

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

to the ones that have the given [`Locality`](Locality).

Trait Implementations

impl<KeySpace, Fetch: FnOnce(Box<dyn Fn(TryIntoSample) + Send + Sync>) -> Result<()> + Send + Sync, TryIntoSample> IntoFuture for FetchingSubscriberBuilder<'_, '_, KeySpace, Callback<Sample>, Fetch, TryIntoSample, true>

where KeySpace: Into<KeySpace>, TryIntoSample: ExtractSample + Send + Sync,

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

The output that the future will produce on completion.

type IntoFuture = Ready<<FetchingSubscriberBuilder<'_, '_, KeySpace, Callback<Sample>, Fetch, TryIntoSample, 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, Fetch: FnOnce(Box<dyn Fn(TryIntoSample) + Send + Sync>) -> Result<()> + Send + Sync, TryIntoSample> IntoFuture for FetchingSubscriberBuilder<'_, '_, KeySpace, Handler, Fetch, TryIntoSample>

where KeySpace: Into<KeySpace>, Handler: IntoHandler<Sample> + Send, Handler::Handler: Send, TryIntoSample: ExtractSample + Send + Sync,

type Output = <FetchingSubscriberBuilder<'_, '_, KeySpace, Handler, Fetch, TryIntoSample> as Resolvable>::To

The output that the future will produce on completion.

type IntoFuture = Ready<<FetchingSubscriberBuilder<'_, '_, KeySpace, Handler, Fetch, TryIntoSample> 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, Fetch: FnOnce(Box<dyn Fn(TryIntoSample) + Send + Sync>) -> Result<()>, TryIntoSample> Resolvable for FetchingSubscriberBuilder<'_, '_, KeySpace, Callback<Sample>, Fetch, TryIntoSample, true>

where TryIntoSample: ExtractSample,

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

impl<KeySpace, Handler, Fetch: FnOnce(Box<dyn Fn(TryIntoSample) + Send + Sync>) -> Result<()>, TryIntoSample> Resolvable for FetchingSubscriberBuilder<'_, '_, KeySpace, Handler, Fetch, TryIntoSample>

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

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

impl<KeySpace, Fetch: FnOnce(Box<dyn Fn(TryIntoSample) + Send + Sync>) -> Result<()> + Send + Sync, TryIntoSample> Wait for FetchingSubscriberBuilder<'_, '_, KeySpace, Callback<Sample>, Fetch, TryIntoSample, true>

where KeySpace: Into<KeySpace>, TryIntoSample: ExtractSample + Send + Sync,

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

Synchronously execute and wait

impl<KeySpace, Handler, Fetch: FnOnce(Box<dyn Fn(TryIntoSample) + Send + Sync>) -> Result<()> + Send + Sync, TryIntoSample> Wait for FetchingSubscriberBuilder<'_, '_, KeySpace, Handler, Fetch, TryIntoSample>

where KeySpace: Into<KeySpace>, Handler: IntoHandler<Sample> + Send, Handler::Handler: Send, TryIntoSample: ExtractSample + Send + Sync,

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

Synchronously execute and wait