pub enum SubscribeError {
TornDown {
node: NodeId,
},
}Expand description
Errors returnable by Core::try_subscribe.
Core::subscribe (the panic-on-error variant) panics on either
case; try_subscribe returns these so operators (zip / concat /
race / take_until / merge / switch_map / etc.) can match on the
variant — skip the source for Self::TornDown.
Per canonical spec R2.2.7.a / R2.2.7.b (D118, 2026-05-10).
Variants§
TornDown
R2.2.7.b (D118, 2026-05-10): the node is non-resubscribable AND
has terminated ([COMPLETE] or [ERROR, h] was delivered).
The stream is permanently over; subscribe is rejected.
Resubscribable terminal nodes do NOT surface this error — they
reset to a fresh lifecycle on subscribe per R2.2.7.a, regardless
of TEARDOWN state.
Trait Implementations§
Source§impl Clone for SubscribeError
impl Clone for SubscribeError
Source§fn clone(&self) -> SubscribeError
fn clone(&self) -> SubscribeError
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for SubscribeError
impl Debug for SubscribeError
Source§impl Display for SubscribeError
impl Display for SubscribeError
Source§impl Error for SubscribeError
impl Error for SubscribeError
1.30.0 · Source§fn source(&self) -> Option<&(dyn Error + 'static)>
fn source(&self) -> Option<&(dyn Error + 'static)>
Returns the lower-level source of this error, if any. Read more
1.0.0 · Source§fn description(&self) -> &str
fn description(&self) -> &str
👎Deprecated since 1.42.0:
use the Display impl or to_string()
Source§impl PartialEq for SubscribeError
impl PartialEq for SubscribeError
Source§fn eq(&self, other: &SubscribeError) -> bool
fn eq(&self, other: &SubscribeError) -> bool
Tests for
self and other values to be equal, and is used by ==.impl Eq for SubscribeError
impl StructuralPartialEq for SubscribeError
Auto Trait Implementations§
impl Freeze for SubscribeError
impl RefUnwindSafe for SubscribeError
impl Send for SubscribeError
impl Sync for SubscribeError
impl Unpin for SubscribeError
impl UnsafeUnpin for SubscribeError
impl UnwindSafe for SubscribeError
Blanket Implementations§
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
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key and return true if they are equal.