Crate futures_01_ext

source ·
Expand description

Crate extending functionality of futures crate

Re-exports

  • pub use futures as futures_reexport;

Modules

  • A layered Decoder adapter for Stream transformations
  • A layered Encoder adapter for Stream transformations
  • Extends the functionality of std::io and ::tokio_io

Macros

  • Macro that can be used like ensure! macro from failure crate, but in the context where the expected return type is BoxFuture. Exits a function early with an Error if the condition is not satisfied.
  • Macro that can be used like ensure! macro from failure crate, but in the context where the expected return type is BoxStream. Exits a function early with an Error if the condition is not satisfied.
  • A convenience macro for working with io::Result<T> from the Read and Write traits.
  • Macro that can be used like ? operator, but in the context where the expected return type is BoxFuture. The result of it is either Ok part of Result or immediate returning the Err part converted into BoxFuture.
  • Macro that can be used like ? operator, but in the context where the expected return type is BoxStream. The result of it is either Ok part of Result or immediate returning the Err part converted into BoxStream.
  • Macro that can be used like ? operator, but in the context where the expected return type is a left future. The result of it is either Ok part of Result or immediate returning the Err

Structs

Enums

Traits

  • A trait implemented by default for all Futures which extends the standard functionality.
  • A trait implemented by default for all Streams which extends the standard functionality.
  • Trait that provides a function for making a decoding layer on top of Stream of Bytes

Functions

  • Creates a stream which returns results of the futures given.
  • Convert a list of streams into a Stream of results from the streams.
  • Send an item over an mpsc channel, discarding both the sender and receiver-closed errors. This should be used when the receiver being closed makes sending values moot, since no one is interested in the results any more.
  • Given an input stream, split its error out to a separate Future, and returning that error Future and an infallable Stream. There are two outcomes:

Type Aliases

  • Replacement for BoxFuture, deprecated in upstream futures-rs.
  • Replacement for BoxFutureNonSend, deprecated in upstream futures-rs.
  • Replacement for BoxStream, deprecated in upstream futures-rs.
  • Replacement for BoxStreamNonSend, deprecated in upstream futures-rs.