pub struct TextStream<CustErr = NoCustomError>(/* private fields */);
Expand description
A stream of text.
A server function can return this type if its output encoding is StreamingText
.
§Browser Support for Streaming Input
Browser fetch requests do not currently support full request duplexing, which means that that they do begin handling responses until the full request has been sent. This means that if you use a streaming input encoding, the input stream needs to end before the output will begin.
Streaming requests are only allowed over HTTP2 or HTTP3.
Implementations§
Source§impl TextStream
impl TextStream
Sourcepub fn new(
value: impl Stream<Item = Result<String, ServerFnError>> + Send + 'static,
) -> TextStream
pub fn new( value: impl Stream<Item = Result<String, ServerFnError>> + Send + 'static, ) -> TextStream
Creates a new ByteStream
from the given stream.
Source§impl<CustErr> TextStream<CustErr>
impl<CustErr> TextStream<CustErr>
Sourcepub fn into_inner(
self,
) -> impl Stream<Item = Result<String, ServerFnError<CustErr>>> + Send
pub fn into_inner( self, ) -> impl Stream<Item = Result<String, ServerFnError<CustErr>>> + Send
Consumes the wrapper, returning a stream of text.
Trait Implementations§
Source§impl<CustErr> Debug for TextStream<CustErr>
impl<CustErr> Debug for TextStream<CustErr>
Source§impl<S, T> From<S> for TextStream
impl<S, T> From<S> for TextStream
Source§fn from(value: S) -> TextStream
fn from(value: S) -> TextStream
Converts to this type from the input type.
Source§impl<CustErr, Response> FromRes<StreamingText, Response, CustErr> for TextStream
impl<CustErr, Response> FromRes<StreamingText, Response, CustErr> for TextStream
Source§async fn from_res(res: Response) -> Result<TextStream, ServerFnError<CustErr>>
async fn from_res(res: Response) -> Result<TextStream, ServerFnError<CustErr>>
Attempts to deserialize the outputs from a response.
Source§impl<CustErr, Response> IntoRes<StreamingText, Response, CustErr> for TextStream<CustErr>where
Response: Res<CustErr>,
CustErr: 'static,
impl<CustErr, Response> IntoRes<StreamingText, Response, CustErr> for TextStream<CustErr>where
Response: Res<CustErr>,
CustErr: 'static,
Source§async fn into_res(self) -> Result<Response, ServerFnError<CustErr>>
async fn into_res(self) -> Result<Response, ServerFnError<CustErr>>
Attempts to serialize the output into an HTTP response.
Auto Trait Implementations§
impl<CustErr> Freeze for TextStream<CustErr>
impl<CustErr = NoCustomError> !RefUnwindSafe for TextStream<CustErr>
impl<CustErr> Send for TextStream<CustErr>
impl<CustErr = NoCustomError> !Sync for TextStream<CustErr>
impl<CustErr> Unpin for TextStream<CustErr>
impl<CustErr = NoCustomError> !UnwindSafe for TextStream<CustErr>
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<CustErr, T, Request> FromReq<StreamingText, Request, CustErr> for T
impl<CustErr, T, Request> FromReq<StreamingText, Request, CustErr> for T
Source§async fn from_req(req: Request) -> Result<T, ServerFnError<CustErr>>
async fn from_req(req: Request) -> Result<T, ServerFnError<CustErr>>
Attempts to deserialize the arguments from a request.
Source§impl<T> InitializeFromFunction<T> for T
impl<T> InitializeFromFunction<T> for T
Source§fn initialize_from_function(f: fn() -> T) -> T
fn initialize_from_function(f: fn() -> T) -> T
Create an instance of this type from an initialization function
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<CustErr, T, Request> IntoReq<StreamingText, Request, CustErr> for T
impl<CustErr, T, Request> IntoReq<StreamingText, Request, CustErr> for T
Source§impl<Ret> SpawnIfAsync<(), Ret> for Ret
impl<Ret> SpawnIfAsync<(), Ret> for Ret
Source§impl<T, O> SuperFrom<T> for Owhere
O: From<T>,
impl<T, O> SuperFrom<T> for Owhere
O: From<T>,
Source§fn super_from(input: T) -> O
fn super_from(input: T) -> O
Convert from a type to another type.
Source§impl<T, O, M> SuperInto<O, M> for Twhere
O: SuperFrom<T, M>,
impl<T, O, M> SuperInto<O, M> for Twhere
O: SuperFrom<T, M>,
Source§fn super_into(self) -> O
fn super_into(self) -> O
Convert from a type to another type.