Skip to main content

ConnectionInterface

Struct ConnectionInterface 

Source
pub struct ConnectionInterface { /* private fields */ }
Expand description

The reciprocal of ConnectionHandle.

Implementations§

Source§

impl ConnectionInterface

Source

pub fn send_to_frontend( &self, item: PubSubItem, ) -> Result<(), SendError<PubSubItem>>

Send a pubsub item to the frontend.

Source

pub async fn recv_from_frontend(&mut self) -> Option<Box<RawValue>>

Receive a request from the frontend. Ensures that if the frontend has dropped or issued a shutdown instruction, the backend sees no more requests.

Source

pub fn close_with_error(self)

Close the interface, signaling a generic backend-gone error to the frontend.

The pubsub service will attempt to reconnect using the configured retry policy. Use Self::close_with_transport_error to opt out of the reconnect loop on deterministic, non-retryable failures.

Source

pub fn close_with_transport_error(self, err: TransportError)

Close the interface, signaling a specific transport error to the frontend.

Use TransportErrorKind::non_retryable_str / TransportErrorKind::non_retryable to construct an error that short-circuits the pubsub service’s reconnect loop. Any other error kind triggers the normal reconnect-with-retries path.

Trait Implementations§

Source§

impl Debug for ConnectionInterface

Source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more

Auto Trait Implementations§

Blanket Implementations§

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

Layout§

Note: Most layout information is completely unstable and may even differ between compilations. The only exception is types with certain repr(...) attributes. Please see the Rust Reference's “Type Layout” chapter for details on type layout guarantees.

Size: 32 bytes