Skip to main content

BatchResults

cratestack_client_rust

Struct BatchResults

pub struct BatchResults { /* private fields */ }

Expand description

Per-handle results from a sent batch. Each handle can be taken exactly once.

Implementations§

impl BatchResults

pub fn take<O>(&mut self, handle: BatchHandle<O>) -> Result<O, RpcClientError>
where O: DeserializeOwned,

Extract the typed output for one queued op. Returns:

Ok(output) — the server emitted an output for this frame and it decoded into O.
Err(RpcClientError::Codec(_)) — the input failed to encode before send, or the output failed to decode.
Err(RpcClientError::Remote(RpcRemoteError { body, .. })) — the server emitted an error frame for this op. The status field is derived from the gRPC-style code in the body since /rpc/batch returns 200 at the HTTP level regardless of per-frame outcomes.
Err(RpcClientError::InvalidResponse(_)) — the server omitted this frame entirely or the frame had neither output nor error set.

Auto Trait Implementations§

impl Freeze for BatchResults

impl RefUnwindSafe for BatchResults

impl Send for BatchResults

impl Sync for BatchResults

impl Unpin for BatchResults

impl UnsafeUnpin for BatchResults

impl UnwindSafe for BatchResults

Blanket Implementations§

impl<T> Any for T
where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> Borrow<T> for T
where T: ?Sized,

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T
where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided [Span], returning an Instrumented wrapper. Read more

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

impl<T, U> Into<U> for T
where U: From<T>,

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T> PolicyExt for T
where T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns [Action::Follow] only if self and other return Action::Follow. Read more

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns [Action::Follow] if either self or other returns Action::Follow. Read more

impl<T> Same for T

type Output = T

Should always be Self

impl<T, U> TryFrom<U> for T
where U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.

impl<T> WithSubscriber for T

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

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a [WithDispatch] wrapper. Read more

impl<A, B, T> HttpServerConnExec<A, B> for T
where B: Body,