pub struct Ticks { /* private fields */ }Expand description
A body the domain produces a piece at a time.
Nothing here names a stream type. The domain states what a chunk is and how the next one is taken, and whichever interpretation carries the answer chooses how the bytes actually move.
Trait Implementations§
Auto Trait Implementations§
impl Freeze for Ticks
impl RefUnwindSafe for Ticks
impl Send for Ticks
impl Sync for Ticks
impl Unpin for Ticks
impl UnsafeUnpin for Ticks
impl UnwindSafe for Ticks
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
Source§impl<This> ChunksExt<This> for This
impl<This> ChunksExt<This> for This
Source§fn moving(
self,
) -> impl Stream<Item = Result<<This as ChunksAlg>::Chunk, <This as ChunksAlg>::Error>>
fn moving( self, ) -> impl Stream<Item = Result<<This as ChunksAlg>::Chunk, <This as ChunksAlg>::Error>>
Reads this body as the sequence of chunks it produces.
Nothing is converted and nothing is carried: a chunk stays what the domain said it was, and a failure stays what the domain said it meant. An interpretation states what to make of either, which is the only part of moving bytes that is its own.
Source§async fn gathered(
self,
) -> Result<Vec<<This as ChunksAlg>::Chunk>, <This as ChunksAlg>::Error>
async fn gathered( self, ) -> Result<Vec<<This as ChunksAlg>::Chunk>, <This as ChunksAlg>::Error>
Takes every chunk this body produces, in the order it produces them.
A sequence read whole is what anything states that cannot act on a piece at a time: a part’s content read into a value, or an answer compared against what a caller would have received.
Source§impl<This> HttpProgramExt<This> for This
impl<This> HttpProgramExt<This> for This
Source§fn compile_http<Program>(
&self,
program: Program,
) -> <Program as HttpProgramAlg<This>>::Routewhere
Program: HttpProgramAlg<This>,
fn compile_http<Program>(
&self,
program: Program,
) -> <Program as HttpProgramAlg<This>>::Routewhere
Program: HttpProgramAlg<This>,
Compiles a named HTTP program with this interpreter.
Source§impl<This> LifecycleApiExt<This> for This
impl<This> LifecycleApiExt<This> for This
Source§fn lifecycle_api<Alg>(&self) -> LifecycleApiProgram<Alg>
fn lifecycle_api<Alg>(&self) -> LifecycleApiProgram<Alg>
Declares one endpoint answering at once and one taking longer than any drain.
Source§impl<This> MultipartApiExt<This> for This
impl<This> MultipartApiExt<This> for This
Source§fn multipart_api<Alg>(&self) -> MultipartApiProgram<Alg>where
Alg: UploadAlg,
fn multipart_api<Alg>(&self) -> MultipartApiProgram<Alg>where
Alg: UploadAlg,
Declares one endpoint reading a body that arrives as parts.
Source§impl<This> ShapeProgramExt<This> for This
impl<This> ShapeProgramExt<This> for This
Source§fn compile_shape<Program>(
&self,
program: Program,
) -> <Program as ShapeProgramAlg<This>>::Tywhere
Program: ShapeProgramAlg<This>,
fn compile_shape<Program>(
&self,
program: Program,
) -> <Program as ShapeProgramAlg<This>>::Tywhere
Program: ShapeProgramAlg<This>,
Folds a declaration with this interpretation.
Source§impl<This> ShopApiExt<This> for This
impl<This> ShopApiExt<This> for This
Source§impl<This> StreamApiExt<This> for This
impl<This> StreamApiExt<This> for This
Source§fn stream_api<Alg>(&self) -> StreamApiProgram<Alg>where
Alg: TicksAlg,
fn stream_api<Alg>(&self) -> StreamApiProgram<Alg>where
Alg: TicksAlg,
Declares one endpoint answering with a body produced over time.