Struct bonsaidb::client::BlockingRemoteSubscriber
pub struct BlockingRemoteSubscriber(_);
Expand description
A remote PubSub Subscriber
that blocks the current thread when
performing requests.
Trait Implementations§
§impl Debug for BlockingRemoteSubscriber
impl Debug for BlockingRemoteSubscriber
§impl Subscriber for BlockingRemoteSubscriber
impl Subscriber for BlockingRemoteSubscriber
§fn subscribe_to_bytes(&self, topic: Vec<u8, Global>) -> Result<(), Error>
fn subscribe_to_bytes(&self, topic: Vec<u8, Global>) -> Result<(), Error>
Subscribe to
Message
s published to topic
.§fn unsubscribe_from_bytes(&self, topic: &[u8]) -> Result<(), Error>
fn unsubscribe_from_bytes(&self, topic: &[u8]) -> Result<(), Error>
Unsubscribe from
Message
s published to topic
.Auto Trait Implementations§
impl !RefUnwindSafe for BlockingRemoteSubscriber
impl Send for BlockingRemoteSubscriber
impl Sync for BlockingRemoteSubscriber
impl Unpin for BlockingRemoteSubscriber
impl !UnwindSafe for BlockingRemoteSubscriber
Blanket Implementations§
§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere T: 'a,
§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere T: 'a,
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more