pub struct AppInvokeStreamStream { /* private fields */ }Expand description
InvokeStream is the streaming counterpart of Invoke. It is gRPC-only (no REST binding) and shares Invoke’s request shape, authorization, and signature policy. The first response frame is always InvokeMetadata; subsequent frames carry data bytes from the operation’s stream response. A mid-stream error may emit a trailing metadata frame with an error status followed by a JSON error body, after which the stream ends.
Stream of converted InvokeFrame frames; transport errors convert to GestaltError.
Implementations§
Source§impl AppInvokeStreamStream
impl AppInvokeStreamStream
Sourcepub async fn recv(&mut self) -> Result<Option<InvokeFrame>, GestaltError>
pub async fn recv(&mut self) -> Result<Option<InvokeFrame>, GestaltError>
Receives the next frame, or None when the stream ends.
Auto Trait Implementations§
impl !RefUnwindSafe for AppInvokeStreamStream
impl !UnwindSafe for AppInvokeStreamStream
impl Freeze for AppInvokeStreamStream
impl Send for AppInvokeStreamStream
impl Sync for AppInvokeStreamStream
impl Unpin for AppInvokeStreamStream
impl UnsafeUnpin for AppInvokeStreamStream
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> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request