[][src]Module scrappy_actor::fut

Custom Future implementation with scrappy_actor support

Structs

Finish

A combinator used to convert a stream into a future; the future resolves when the stream completes.

FutureResult

A future representing a value that is immediately ready.

FutureWrap
Map

Future for the map combinator, changing the type of a future.

Ready

Future for the ready function.

StreamFinish

A combinator used to convert stream into a future, future resolves when stream completes.

StreamFold

A future used to collect all the results of a stream into one generic type.

StreamMap

A stream combinator which will change the type of a stream from one type to another.

StreamThen

A stream combinator which chains a computation onto each item produced by a stream.

StreamTimeout

Future for the timeout combinator, interrupts computations if it takes more than timeout.

StreamWrap
Then

Future for the then combinator, chaining computations on the end of another future regardless of its outcome.

Timeout

Future for the timeout combinator, interrupts computations if it takes more than timeout.

Enums

Either

Combines two different futures yielding the same item and error types into a single type.

Traits

ActorFuture

Trait for types which are a placeholder of a value that may become available at some later point in time.

ActorStream

A stream of values, not all of which may have been produced yet.

IntoActorFuture

Class of types which can be converted into an actor future.

WrapFuture

Helper trait that allows conversion of normal future into ActorFuture

WrapStream

Helper trait that allows conversion of normal stream into ActorStream

Functions

err

Creates a "leaf future" from an immediate value of a failed computation.

ok

Creates a "leaf future" from an immediate value of a finished and successful computation.

ready

Create a future that is immediately ready with a value.

result

Creates a new "leaf future" which will resolve with the given result.

wrap_future

Converts normal future into ActorFuture, allowing its processing to use the actor's state.

wrap_stream

Converts normal stream into ActorStream