Yoshua Wuyts
c82b1efb69
fix(stream): add send guards on collect
...
Closes #639
Co-authored-by: dignifiedquire <me@dignifiedquire.com>
2020-06-27 16:46:14 +02:00
Yoshua Wuyts
6c1b5eb3ed
Merge pull request #667 from olegnn/option_take_while
...
Use `take_while` instead of `scan` in `impl` of `Product`, `Sum` and `FromStream` for `Option` and `Result`
2020-01-27 11:54:20 +01:00
Oleg Nosov
ed7ddacb28
Rewrote Results implementation using take_while and filter_map
2020-01-17 17:19:51 +03:00
Oleg Nosov
ed248017b4
Use internal scan state in Results implementation
2020-01-15 12:06:50 +03:00
Oleg Nosov
134089af2c
Use filter_map(identity) + other fixes
2020-01-15 08:57:43 +03:00
Yoshua Wuyts
5d5064b871
add FromStream Result example ( #643 )
...
Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>
2020-01-13 21:42:31 +01:00
Grzegorz Gierlach
f0875d2dca
Cleaning up stream pinning.
2019-11-12 19:34:08 +01:00
Stjepan Glavina
548733e5d5
Cleanup stream traits ( #487 )
...
* Cleanup stream traits
* Fix docs
2019-11-09 11:22:09 +01:00
nasa
ddbbbfc32a
Replace VecDeque with stream::from_iter in examples ( #447 )
2019-11-03 13:40:51 +01:00
Kyle Tomsic
e26eb7a719
Add Stream::sum() and Stream::product() implementations
...
These are the stream equivalents to `std::iter::Iterator::sum()` and
`std::iter::Iterator::product()`.
Note that this changeset tweaks the `Stream::Sum` and `Stream::Product`
traits a little: rather than returning a generic future `F`, they return
a pinned, boxed, `Future` trait object now. This is in line with other
traits that return a future, e.g. `FromStream`.
2019-10-22 20:30:27 -04:00
Sunjay Varma
fb7582bd7a
Using Box::pin(...) instead of Pin::from(Box::new(...))
2019-09-30 19:42:30 -04:00
Stjepan Glavina
edfa2358a4
Re-export IO traits from futures
2019-09-21 14:30:52 +02:00
Sunjay Varma
c87dab2d5e
rustfmt
2019-09-17 16:48:58 -04:00
Sunjay Varma
ad0510110c
Added the ability to collect a stream of results
2019-09-17 16:25:26 -04:00
