pub struct KeepAlive { /* private fields */ }Expand description
Configure the interval between keep-alive messages, the content of each message, and the associated stream.
Implementations
sourceimpl KeepAlive
impl KeepAlive
sourcepub fn interval(self, time: Duration) -> KeepAlive
pub fn interval(self, time: Duration) -> KeepAlive
Customize the interval between keep-alive messages.
Default is 15 seconds.
sourcepub fn text(self, text: impl Into<Cow<'static, str>>) -> KeepAlive
pub fn text(self, text: impl Into<Cow<'static, str>>) -> KeepAlive
Customize the text of the keep-alive message.
Default is an empty comment.
sourcepub fn stream<S>(
self,
event_stream: S
) -> impl TryStream<Ok = Event, Error = impl Error + Send + Sync + 'static> + Send + 'static where
S: 'static + TryStream<Ok = Event> + Send,
<S as TryStream>::Error: 'static,
<S as TryStream>::Error: Error,
<S as TryStream>::Error: Send,
<S as TryStream>::Error: Sync,
pub fn stream<S>(
self,
event_stream: S
) -> impl TryStream<Ok = Event, Error = impl Error + Send + Sync + 'static> + Send + 'static where
S: 'static + TryStream<Ok = Event> + Send,
<S as TryStream>::Error: 'static,
<S as TryStream>::Error: Error,
<S as TryStream>::Error: Send,
<S as TryStream>::Error: Sync,
Wrap an event stream with keep-alive functionality.
See keep_alive for more.
Trait Implementations
Auto Trait Implementations
impl RefUnwindSafe for KeepAlive
impl Send for KeepAlive
impl Sync for KeepAlive
impl Unpin for KeepAlive
impl UnwindSafe for KeepAlive
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>ⓘNotable traits for Instrumented<T>impl<T> Future for Instrumented<T> where
T: Future, type Output = <T as Future>::Output;
fn instrument(self, span: Span) -> Instrumented<Self>ⓘNotable traits for Instrumented<T>impl<T> Future for Instrumented<T> where
T: Future, type Output = <T as Future>::Output;
T: Future, type Output = <T as Future>::Output;
sourcefn in_current_span(self) -> Instrumented<Self>ⓘNotable traits for Instrumented<T>impl<T> Future for Instrumented<T> where
T: Future, type Output = <T as Future>::Output;
fn in_current_span(self) -> Instrumented<Self>ⓘNotable traits for Instrumented<T>impl<T> Future for Instrumented<T> where
T: Future, type Output = <T as Future>::Output;
T: Future, type Output = <T as Future>::Output;
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>ⓘNotable traits for WithDispatch<T>impl<T> Future for WithDispatch<T> where
T: Future, type Output = <T as Future>::Output; where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>ⓘNotable traits for WithDispatch<T>impl<T> Future for WithDispatch<T> where
T: Future, type Output = <T as Future>::Output; where
S: Into<Dispatch>,
T: Future, type Output = <T as Future>::Output;
Attaches the provided Subscriber to this type, returning a
WithDispatch wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>ⓘNotable traits for WithDispatch<T>impl<T> Future for WithDispatch<T> where
T: Future, type Output = <T as Future>::Output;
fn with_current_subscriber(self) -> WithDispatch<Self>ⓘNotable traits for WithDispatch<T>impl<T> Future for WithDispatch<T> where
T: Future, type Output = <T as Future>::Output;
T: Future, type Output = <T as Future>::Output;
Attaches the current default Subscriber to this type, returning a
WithDispatch wrapper. Read more