Struct postgres::Notifications
source · [−]pub struct Notifications<'a> { /* private fields */ }
Expand description
Notifications from a PostgreSQL backend.
Implementations
sourceimpl<'a> Notifications<'a>
impl<'a> Notifications<'a>
sourcepub fn is_empty(&self) -> bool
pub fn is_empty(&self) -> bool
Determines if there are any already buffered pending notifications.
sourcepub fn iter(&mut self) -> Iter<'_>
pub fn iter(&mut self) -> Iter<'_>
Returns a nonblocking iterator over notifications.
If there are no already buffered pending notifications, this iterator will poll the connection but will not
block waiting on notifications over the network. A return value of None
either indicates that there are no
pending notifications or that the server has disconnected.
Note
This iterator may start returning Some
after previously returning None
if more notifications are received.
sourcepub fn blocking_iter(&mut self) -> BlockingIter<'_>
pub fn blocking_iter(&mut self) -> BlockingIter<'_>
Returns a blocking iterator over notifications.
If there are no already buffered pending notifications, this iterator will block indefinitely waiting on the
PostgreSQL backend server to send one. It will only return None
if the server has disconnected.
sourcepub fn timeout_iter(&mut self, timeout: Duration) -> TimeoutIter<'_>
pub fn timeout_iter(&mut self, timeout: Duration) -> TimeoutIter<'_>
Returns an iterator over notifications which blocks a limited amount of time.
If there are no already buffered pending notifications, this iterator will block waiting on the PostgreSQL
backend server to send one up to the provided timeout. A return value of None
either indicates that there are
no pending notifications or that the server has disconnected.
Note
This iterator may start returning Some
after previously returning None
if more notifications are received.
Auto Trait Implementations
impl<'a> !RefUnwindSafe for Notifications<'a>
impl<'a> Send for Notifications<'a>
impl<'a> !Sync for Notifications<'a>
impl<'a> Unpin for Notifications<'a>
impl<'a> !UnwindSafe for Notifications<'a>
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
fn vzip(self) -> V
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
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
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more