FetchingSubscriberBuilder

zenoh_ext

Struct FetchingSubscriberBuilder 

Source 
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.
Expand description

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§

Source§

impl<'a, 'b, KeySpace, Fetch: FnOnce(Box<dyn Fn(TryIntoSample) + Send + Sync>) -> Result<()>, TryIntoSample> FetchingSubscriberBuilder<'a, 'b, KeySpace, DefaultHandler, Fetch, TryIntoSample>
where TryIntoSample: ExtractSample,

Source

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.
Source

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.

Source

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.
Source§

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,

Source

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

👎Deprecated: Use AdvancedPublisher and AdvancedSubscriber instead.

Make the subscriber to 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.

Source§

impl<Handler, Fetch: FnOnce(Box<dyn Fn(TryIntoSample) + Send + Sync>) -> Result<()>, TryIntoSample, const BACKGROUND: bool> FetchingSubscriberBuilder<'_, '_, UserSpace, Handler, Fetch, TryIntoSample, BACKGROUND>
where TryIntoSample: ExtractSample,

Source

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§

Source§

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,

Available on crate feature unstable only.
Source§

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

The output that the future will produce on completion.
Source§

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

Which kind of future are we turning this into?
Source§

fn into_future(self) -> Self::IntoFuture

Creates a future from a value. Read more
Source§

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,

Available on crate feature unstable only.
Source§

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

The output that the future will produce on completion.
Source§

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

Which kind of future are we turning this into?
Source§

fn into_future(self) -> Self::IntoFuture

Creates a future from a value. Read more
Source§

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

Available on crate feature unstable only.
Source§

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

Source§

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,

Available on crate feature unstable only.
Source§

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

Source§

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,

Available on crate feature unstable only.
Source§

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

Synchronously execute and wait
Source§

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,

Available on crate feature unstable only.
Source§

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

Synchronously execute and wait

Auto Trait Implementations§

§

impl<'a, 'b, KeySpace, Handler, Fetch, TryIntoSample, const BACKGROUND: bool> Freeze for FetchingSubscriberBuilder<'a, 'b, KeySpace, Handler, Fetch, TryIntoSample, BACKGROUND>
where KeySpace: Freeze, Fetch: Freeze, Handler: Freeze,

§

impl<'a, 'b, KeySpace, Handler, Fetch, TryIntoSample, const BACKGROUND: bool = false> !RefUnwindSafe for FetchingSubscriberBuilder<'a, 'b, KeySpace, Handler, Fetch, TryIntoSample, BACKGROUND>

§

impl<'a, 'b, KeySpace, Handler, Fetch, TryIntoSample, const BACKGROUND: bool> Send for FetchingSubscriberBuilder<'a, 'b, KeySpace, Handler, Fetch, TryIntoSample, BACKGROUND>
where KeySpace: Send, Fetch: Send, Handler: Send, TryIntoSample: Send,

§

impl<'a, 'b, KeySpace, Handler, Fetch, TryIntoSample, const BACKGROUND: bool> Sync for FetchingSubscriberBuilder<'a, 'b, KeySpace, Handler, Fetch, TryIntoSample, BACKGROUND>
where KeySpace: Sync, Fetch: Sync, Handler: Sync, TryIntoSample: Sync,

§

impl<'a, 'b, KeySpace, Handler, Fetch, TryIntoSample, const BACKGROUND: bool> Unpin for FetchingSubscriberBuilder<'a, 'b, KeySpace, Handler, Fetch, TryIntoSample, BACKGROUND>
where KeySpace: Unpin, Fetch: Unpin, Handler: Unpin, TryIntoSample: Unpin,

§

impl<'a, 'b, KeySpace, Handler, Fetch, TryIntoSample, const BACKGROUND: bool = false> !UnwindSafe for FetchingSubscriberBuilder<'a, 'b, KeySpace, Handler, Fetch, TryIntoSample, BACKGROUND>

Blanket Implementations§

Source§

impl<Source> AccessAs for Source

Source§

fn ref_as<T>(&self) -> <Source as IGuardRef<T>>::Guard<'_>
where Source: IGuardRef<T>, T: ?Sized,

Provides immutable access to a type as if it were its ABI-unstable equivalent.
Source§

fn mut_as<T>(&mut self) -> <Source as IGuardMut<T>>::GuardMut<'_>
where Source: IGuardMut<T>, T: ?Sized,

Provides mutable access to a type as if it were its ABI-unstable equivalent.
Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> AsNode<T> for T

Source§

fn as_node(&self) -> &T

Source§

impl<T> AsNodeMut<T> for T

Source§

fn as_node_mut(&mut self) -> &mut T

Source§

impl<'a, T, E> AsTaggedExplicit<'a, E> for T
where T: 'a,

Source§

fn explicit(self, class: Class, tag: u32) -> TaggedParser<'a, Explicit, Self, E>

Source§

impl<'a, T, E> AsTaggedImplicit<'a, E> for T
where T: 'a,

Source§

fn implicit( self, class: Class, constructed: bool, tag: u32, ) -> TaggedParser<'a, Implicit, Self, E>

Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, As> IGuardMut<As> for T
where T: Into<As>, As: Into<T>,

Source§

type GuardMut<'a> = MutAs<'a, T, As> where T: 'a

The type of the guard which will clean up the temporary after applying its changes to the original.
Source§

fn guard_mut_inner(&mut self) -> <T as IGuardMut<As>>::GuardMut<'_>

Construct the temporary and guard it through a mutable reference.
Source§

impl<T, As> IGuardRef<As> for T
where T: Into<As>, As: Into<T>,

Source§

type Guard<'a> = RefAs<'a, T, As> where T: 'a

The type of the guard which will clean up the temporary.
Source§

fn guard_ref_inner(&self) -> <T as IGuardRef<As>>::Guard<'_>

Construct the temporary and guard it through an immutable reference.
Source§

impl<T> Includes<End> for T

Source§

type Output = End

The result
Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

impl<T> Pointable for T

Source§

const ALIGN: usize

The alignment of pointer.
Source§

type Init = T

The type for initializers.
Source§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
Source§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
Source§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
Source§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

impl<T> ErasedDestructor for T
where T: 'static,

Source§

impl<T> MaybeSendSync for T

Source§

impl<T, Output> Resolve<Output> for T
where T: Wait<To = Output> + IntoSendFuture + IntoFuture<IntoFuture = <T as IntoSendFuture>::IntoFuture, Output = Output> + Resolvable + Send,