Commit Graph

855 Commits (1d875836a2302681a395ee44512a518f0222da4a)

Author SHA1 Message Date
Stjepan Glavina 6677d52c2d Improve thread creating algorithm in spawn_blocking 5 years ago
Johannes Weissmann 37922408e5 use pin_project 5 years ago
Johannes Weissmann 7d2282dbd2 fix merge conflict 5 years ago
Johannes Weissmann 60f822bee5 Merge branch 'master' into stream_count 5 years ago
Yoshua Wuyts 4aa9928ece
v1.0.0
Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>
5 years ago
Stjepan Glavina 5438258cee Remove unused import 5 years ago
Wouter Geraedts ef958f0408 Use pin_project_lite instead for throttle 5 years ago
Stjepan Glavina dc5d143c16 Merge branch 'master' into cleanup-stream 5 years ago
Stjepan Glavina c2f750d288 Cleanup stream module 5 years ago
Wouter Geraedts 139a34b685 Make throttle an unstable feature 5 years ago
Wouter Geraedts b591fc68bd Changed semantics of throttle to non-dropping variant with backpressure 5 years ago
razican 5d558ca213
Fixed test, order is no longer guaranteed 5 years ago
razican e48e463736
Duplicating code due to strange Rust error. 5 years ago
razican 0c37d4af10
Anonymous function to avoid type issues 5 years ago
Stjepan Glavina 352f18bc2a
Use async_std::sync::Arc in examples (#501) 5 years ago
razican 79bbf4938d
Randomize Stream::merge to improve the throughput. Implements #490. 5 years ago
Wouter Geraedts 14d7d3bf9c Merge remote-tracking branch 'upstream/master' into 342-stream-throttle 5 years ago
Stjepan Glavina 417b548692
Cleanup path module (#497)
* Cleanup path module

* Derive clone for PathBuf and remove unused import

* impl AsRef<Path> for std::path::PathBuf

* Fix a doc comment
5 years ago
Stjepan Glavina 122e87364b Remove cache padding in channels 5 years ago
Stjepan Glavina d4f38e783f Cleanup future module 5 years ago
Yoshua Wuyts 96d3560742 remove future::*join macros (#492)
Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>
5 years ago
Yoshua Wuyts ac1042a9ca note on Stream::merge ordering (#491)
* note on Stream::merge ordering

Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>

* Update src/stream/stream/mod.rs
5 years ago
Stjepan Glavina 9e185f1c3e
Unstable feature: copy takes arguments by value (#471)
* Unstable feature: copy takes arguments by value

* Fix feature flags
5 years ago
Yoshua Wuyts 89d611628a
Merge pull request #483 from ryan-scott-dev/rscott/pathbuf_fromiter
Add FromIterator and Extend trait implementations for PathBuf
5 years ago
Jayson Reis d8e52c1002
Implement FromStr for PathBuf
This makes PathBuf compatible with std version as you can simply call
let path: PathBuf = FromStr::from_str(s).unwrap()
5 years ago
Yoshua Wuyts 037119c0c0
Merge pull request #478 from portgasd666/master
Add Future::join and Future::try_join
5 years ago
Stjepan Glavina 548733e5d5
Cleanup stream traits (#487)
* Cleanup stream traits

* Fix docs
5 years ago
Abhishek C. Sharma f04b6f6fe9 Change module level docs for future to refer to join and try_join functions instead of macros 5 years ago
Friedel Ziegelmayer 4a78f731b7 fix: stream::take_while (#485)
When the predicate is false, the stream should be ended.
5 years ago
Ryan Scott 8f3366072f Add FromIterator and Extend trait implementations for PathBuf 5 years ago
laizy fb19ebde17 add `Sync` constraint for RwLock to prevent memory unsafety (#479) 5 years ago
Abhishek C. Sharma b14282457c Add Future::join and Future::try_join 5 years ago
Stjepan Glavina ab2f64cd84 Mark extend() as unstable 5 years ago
Yoshua Wuyts 335bd34470 Add "std" feature flag (#476)
* core feature

Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>

* introduce std + default features

Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>

* test std features on ci

Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>

* finish up all features

Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>

* Fix task_local macro

* Remove crossbeam-channel and futures-timer from std

* Move future::timeout() behind cfg_default
5 years ago
Stjepan Glavina f588ba6bdd
Spawn more than one blocking thread (#475)
* Spawn more than 1 blocking thread

* Fix a bug

* Fix check when the thread is last sleeping
5 years ago
Yoshua Wuyts 84880c4d8b re-export async-attributes (#238)
* re-export async-attributes

Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>

* doc order

Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>

* rebase + rename feature to "attributes"

Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>

* only expose test and main

Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>

* async-attributes 1.1.0

Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>
5 years ago
Stjepan Glavina bc24503382
Fix deadlock when all receivers are dropped (#474)
* Fix deadlock when all receivers are dropped

* Add a comment to explain the behavior of try_send

* Disable clippy
5 years ago
Yoshua Wuyts 266e6326eb document path submodule (#467)
Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>
5 years ago
Stjepan Glavina f8e82564d9
Rename stream_extend to extend (#464)
* Rename stream_extend to extend

* Remove Extend from prelude

* Add stream::extend()
5 years ago
Abhishek C Sharma eb1ef3f4e4 Minor documentation fix for race and try_race (#473) 5 years ago
Yoshua Wuyts d0f1996759
Merge pull request #388 from felipesere/cycle
Implement stream::cycle(..)
5 years ago
Yoshua Wuyts 8a0e29473a
Merge pull request #446 from yjhmelody/stream-cloned
Add Stream cloned
5 years ago
Yoshua Wuyts 929027796e
hide future::Flatten
Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>
5 years ago
Yoshua Wuyts 9a8805678e
Merge pull request #443 from portgasd666/master
Added Future::flatten
5 years ago
Yoshua Wuyts a064a5b13e
Merge pull request #459 from stjepang/expose-ext-traits
Expose extension traits in preludes
5 years ago
Stjepan Glavina c34e0f8a35
Update futures to 0.3 (#463)
* Update futures to 0.3

* Fix a search-and-replace error

* Fix imports in tests

* Fix an import
5 years ago
Stjepan Glavina 93b01e36ed
Clippy fixes (#462) 5 years ago
Gabriel Majeri d502453057 Remove doc `Stream` impl for `VecDeque` (#461) 5 years ago
Yoshua Wuyts 3144e217ae
Merge pull request #458 from async-rs/rework-intro
rework lib.rs docs
5 years ago
Stjepan Glavina c3254d78d9 Fix a re-rexport 5 years ago
Yoshua Wuyts f4fb8a3534
change one line
Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>
5 years ago
Yoshua Wuyts 1c87e97e9c
Apply suggestions from code review
Co-Authored-By: Stjepan Glavina <stjepang@gmail.com>
5 years ago
Stjepan Glavina a757cc02dc Expose extension traits in preludes 5 years ago
Yoshua Wuyts ae8b051892
rework lib.rs docs
Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>
5 years ago
Stjepan Glavina 1707638ebb
Update mod.rs 5 years ago
Yoshua Wuyts 84fa4ca068
Merge pull request #456 from stjepang/doc-fixes-links
Fix some links in docs
5 years ago
Stjepan Glavina 43bb59cd02 Fix some links in docs 5 years ago
yjh 5179f30d2d
use async_std::stream 5 years ago
yjh a35602f375
Update mod.rs 5 years ago
Yoshua Wuyts e14cc2a30d
Merge pull request #452 from stjepang/fix-deadlocks
Fix a deadlock in channel
5 years ago
Stjepan Glavina 6d421de992 Fix another clippy warning 5 years ago
Stjepan Glavina 5874392397 Fix a clippy warning 5 years ago
Stjepan Glavina e9edadffc7 Fix a deadlock in channel 5 years ago
Yoshua Wuyts 282ae064fe
Merge pull request #449 from async-rs/strip-vecdeque
remove remaining instances of VecDeque stream
5 years ago
yjh e85bbe68e6
Merge branch 'master' into stream-cloned 5 years ago
Abhishek C. Sharma d7afcada76 Fixed ambiguous associated types 5 years ago
Abhishek C. Sharma e36172e808 Merge remote-tracking branch 'upstream/master' 5 years ago
Abhishek C. Sharma a3e68704bc Wrap state enum in public struct 5 years ago
yjh 8bef812e78
Update src/stream/stream/cloned.rs
Co-Authored-By: nasa <htilcs1115@gmail.com>
5 years ago
yjh bf0cd5987a
Update src/stream/stream/cloned.rs
Co-Authored-By: nasa <htilcs1115@gmail.com>
5 years ago
Stjepan Glavina 20cdf73bb0
Simplify RwLock using WakerSet (#440) 5 years ago
Yoshua Wuyts ed1cb49807
remove remaining instances of VecDeque stream
Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>
5 years ago
Stjepan Glavina 78614c6c1d
Clarify blocking in channel docs (#448) 5 years ago
nasa ddbbbfc32a Replace `VecDeque` with `stream::from_iter` in examples (#447) 5 years ago
yjhmelody 4942dc7f9f Add Stream cloned 5 years ago
Abhishek C. Sharma e0910be8fb Added Future::flatten 5 years ago
Felipe Sere 57a6516e63 Make bounds on Stream impl simpler 5 years ago
Felipe Sere fbd5bd867d Revert "Only one generic type needed"
This reverts commit e9b9284863a614b852c22d58205cb983fc26682a.
5 years ago
Felipe Sere 9ee804f9ed Only one generic type needed 5 years ago
Felipe Seré eaa56580e3 Update src/stream/stream/mod.rs
Co-Authored-By: Yoshua Wuyts <yoshuawuyts+github@gmail.com>
5 years ago
Felipe Sere 0186124aef Simpler impl 5 years ago
Felipe Sere 197253aa73 Run fmt 5 years ago
Felipe Sere 19381fa590 One clippy warning 5 years ago
Felipe Sere ed5b095c73 Run fmt 5 years ago
Felipe Sere 5aadc5e4e9 Make cycle a function on the stream type 5 years ago
Felipe Sere b979773505 Follow clippys advice 5 years ago
Felipe Sere fd09e2f248 Run fmt 5 years ago
Felipe Sere 171cc82aed Replace copy with clone bound 5 years ago
Felipe Sere 83ff11ff4c Switch cycle to stream 5 years ago
Felipe Sere e1ba87e7c1 Add slightly better docs 5 years ago
Felipe Sere 8126bb1882 use the module operator to calculate next index 5 years ago
Felipe Sere 486f9a964c Cycle over a known set of values. 5 years ago
Felipe Sere a096d5ec2d stub out an example 5 years ago
Felipe Sere dea1b67670 Skeleton cycle 5 years ago
Aleksey Kladov fa91d7f856 Stream::merge does not end prematurely if one stream is delayed (#437)
* Stream::merge does not end prematurely if one stream is delayed

* `cargo test` without features works

* Stream::merge works correctly for unfused streams
5 years ago
Yoshua Wuyts 9a4f4c591c
Merge pull request #441 from async-rs/stdio-lock-unstable
mark stdio-lock structs as unstable
5 years ago
Yoshua Wuyts 6f9436e575
mark stdio-lock structs as unstable
Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>
5 years ago
Yoshua Wuyts 735fa6954e Replace select!/try_select! with Future::{race,try_race} (#405)
* init Future::select

Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>

* implement Future::select

Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>

* try_select

Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>

* fixes

Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>

* works

Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>

* pass clippy

Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>

* please clippy

Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>

* implement feedback from stjepan

Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>

* rename select to race

Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>

* fmt

Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>
5 years ago
yjh 3a2e6d5b92 add max_by_key (#408)
* add max_by_key

* fix conflict

* fmt code
5 years ago
Zhang Guyu 5fb9d3e980 add Stream::copied (#442) 5 years ago
Yoshua Wuyts 4c63392a85
Merge pull request #334 from k-nasa/add_stdin_lock
Locking for stdin
5 years ago
k-nasa 3dcad984b4 fix: To unstable feature 5 years ago
Yoshua Wuyts 911ebada0b
Merge pull request #434 from paulocsanz/master
Put everything behind a 'stable' feature to avoid future breaking changes
5 years ago
Aleksey Kladov ec1a6ea3e8 Fix typo (#439) 5 years ago
Tyler Neely 5adc608791 Spawn several threads when we fail to enqueue work in the blocki… (#181)
* Rebase onto master

* Switch to unbounded channels
5 years ago
k-nasa 81873ae5f3 fix 5 years ago
Paulo 8e991bcd3a Fix typo 5 years ago
Paulo 2e66c38453 Simplify default feature 5 years ago
k-nasa 0661f774c2 Merge branch 'master' into add_stdin_lock 5 years ago
k-nasa 2f3c867d44 Merge branch 'master' into stream_from_iter 5 years ago
k-nasa 063798ce49 Add doc 5 years ago
Yoshua Wuyts a3b742188d fix doc tests (#431)
* fix doc tests

Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>

* cargo fmt

Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>
5 years ago
Paulo dcd7c55cef Put everything behind a 'stable' feature 5 years ago
Stjepan Glavina 87de4e1598
Add utility type WakerSet to the sync module (#390)
* Add utility type Registry to the sync module

* Remove unused import

* Split unregister into complete and cancel

* Refactoring and renaming

* Split remove() into complete() and cancel()

* Rename to WakerSet

* Ignore clippy warning

* Ignore another clippy warning

* Use stronger SeqCst ordering
5 years ago
Stjepan Glavina 3dd59d7056
Refactor the task module (#421)
* Refactor the task module

* Fix clippy warning

* Simplify task-local entries

* Reduce the amount of future wrapping

* Cleanup

* Simplify stealing
5 years ago
k-nasa caa23381f0 fix clippy warning 5 years ago
k-nasa eeb44c86e9 fix 5 years ago
k-nasa f8b8c9debe Merge branch 'master' into add_stdin_lock 5 years ago
Yoshua Wuyts cc75b65b8c
Merge pull request #409 from yjhmelody/stream-min
Add Stream min
5 years ago
Yoshua Wuyts f102588df5
Merge pull request #428 from zhangguyu6/stream-position
Add stream position
5 years ago
Yoshua Wuyts 3e0fe742f6
Merge pull request #427 from yjhmelody/stream-ne
Add stream ne
5 years ago
zhangguyu 07d21e5eb3 change trait bounds 5 years ago
zhangguyu 48c82a9668 Add stream position 5 years ago
yjhmelody 1ab3d901e4 fmt code 5 years ago
yjhmelody 204da33391 fmt code 5 years ago
yjhmelody 17db7ffcd3 Add stream ne 5 years ago
yjhmelody f5efaaa7ba Add stream eq 5 years ago
Wu Yu Wei ff6a44fcd5 Use once_cell instead of lazy_static (#416)
`once_cell` provides a neat way of initializing lazy singletons without
macro. This PR use `sync::Lazy` to streamline same pattern proposed in
related rust RFC.

Resolve #406
5 years ago
k-nasa 40c4e1a29d feat: Add stream::from_iter 5 years ago
k-nasa 2c91b30ee8 feat: Add Read and Write trait to Lock struct 5 years ago
yjhmelody 021862dcc8 fix min 5 years ago
yjhmelody b942d0a405 add stream-min 5 years ago
Yoshua Wuyts 2b1c6f04ea
Merge pull request #384 from yjhmelody/stream-max_by
add stream::max_by method
5 years ago
Yoshua Wuyts 5ff4ef8dd4
Merge pull request #385 from yjhmelody/stream-min_by_key
add stream::min_by_key method
5 years ago
Yoshua Wuyts f311e3de9f
Merge pull request #397 from async-rs/sync-docs
add mod level docs for sync
5 years ago
Yoshua Wuyts 3a06a1211b
Add feedback from review
Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>
5 years ago
Yoshua Wuyts 526c4da21a
Merge pull request #395 from async-rs/stream-docs
add stream mod docs
5 years ago
Yoshua Wuyts 997e811c58
Merge pull request #402 from async-rs/fuse-docs
update Stream::fuse docs
5 years ago
Yoshua Wuyts 11d0577407
Merge pull request #396 from async-rs/net-docs
standardize net docs
5 years ago
Yoshua Wuyts eb081b1948
Apply suggestions from code review
Co-Authored-By: Florian Gilcher <florian.gilcher@ferrous-systems.com>
5 years ago
k-nasa 35cb11e398 Merge branch 'master' into add_stdin_lock 5 years ago
Yoshua Wuyts 1175a37c47
Merge pull request #367 from k-nasa/add_stream_flatten
Add Stream::flatten and Stream::flat_map
5 years ago
k-nasa 1554b04407 $cargo fmt 5 years ago
k-nasa 1545d24e50 Merge branch 'master' into add_future_delay 5 years ago
k-nasa ae7adf2c36 fix: Remove unused import 5 years ago
k-nasa 040227f38a Merge branch 'master' into add_stream_flatten 5 years ago
k-nasa 688976203e fix: Split FlattenCompat logic to Flatten and FlatMap 5 years ago
k-nasa c7dc147f73 fix indent 5 years ago
Yoshua Wuyts b3ae6f2b03
update Stream::fuse docs
Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>
5 years ago
Yoshua Wuyts 4346386610
fix doc recursion limit
Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>
5 years ago
Yoshua Wuyts ca4856a0e8
Merge pull request #377 from ktomsic/sum-and-product-impls
Add `Stream::sum()` and `Stream::product()` implementations
5 years ago
Yoshua Wuyts e5675151b9
Merge pull request #364 from stjepang/optimize-flushing
Don't flush files if they weren't written to
5 years ago
Yoshua Wuyts fd940b8c6a
Merge pull request #348 from k-nasa/add_stream_timeout
Add stream timeout
5 years ago
Yoshua Wuyts 1baee98ead
Merge pull request #375 from sunjay/fromstream-pathbuf
Added Extend + FromStream for PathBuf
5 years ago
k-nasa 613895d6be doc: fix documantation text 5 years ago
Florian Gilcher f262fd8a40
Merge pull request #392 from taiki-e/clippy
Remove usage of actions-rs/clippy-check
5 years ago
Florian Gilcher c2a084ed4a
Merge pull request #393 from k-nasa/fix_clippy
Fix clippy warnings
5 years ago
Yoshua Wuyts 5f8e2cbd4a
add mod level docs for sync
Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>
5 years ago
Yoshua Wuyts 20abd5cebf
standardize net docs
Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>
5 years ago
Yoshua Wuyts 4c4604d63e
add stream mod docs
Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>
5 years ago
Yoshua Wuyts 4475a229d6
backlink io docs
Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>
5 years ago
Yoshua Wuyts a3a740c14a
backlink all docs
Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>
5 years ago
k-nasa 59615a655b feat: Add StderrLock and StdoutLock struct 5 years ago
k-nasa fe49f2618f fix clippy::redundant_clone 5 years ago
k-nasa 7c293d37f7 fix clippy::comparison_chain 5 years ago
nasa a42ae2f3d9
Narrow the disclosure range of FlattenCompat::new
Co-Authored-By: Taiki Endo <te316e89@gmail.com>
5 years ago
nasa 37f14b0195
Narrow the disclosure range of Flatten::new
Co-Authored-By: Taiki Endo <te316e89@gmail.com>
5 years ago
nasa 13a08b0d54
Narrow the disclosure range of FlatMap::new
Co-Authored-By: Taiki Endo <te316e89@gmail.com>
5 years ago
Johannes Weissmann 75546ef831 Merge branch 'master' into stream_count 5 years ago
Johannes Weissmann 6608d39c59 remove Stream trait bound 5 years ago
Taiki Endo 6549b66ad2 run clippy check on beta & address clippy warnings 5 years ago
yjhmelody 7cfec4e8ce use take and remove Copy 5 years ago
yjh fb78ed1812
Update src/stream/stream/min_by_key.rs
Co-Authored-By: Taiki Endo <te316e89@gmail.com>
5 years ago
yjh 5a4fdeb1cd
Update src/stream/stream/min_by_key.rs
Co-Authored-By: Taiki Endo <te316e89@gmail.com>
5 years ago
yjh b57849e1cb
Update src/stream/stream/max_by.rs
Co-Authored-By: Taiki Endo <te316e89@gmail.com>
5 years ago
yjh a8d3d1483f
Update src/stream/stream/max_by.rs
Co-Authored-By: Taiki Endo <te316e89@gmail.com>
5 years ago
yjh 006fc7e9de
Update src/stream/stream/max_by.rs
Co-Authored-By: Taiki Endo <te316e89@gmail.com>
5 years ago
yjhmelody c9e6d3a84c use pin_project_lite 5 years ago
yjhmelody 37a7eadf17 use pin_project_lite 5 years ago
yjhmelody d0c3c9172b Merge branch 'master' of git://github.com/async-std/async-std into stream-max_by 5 years ago
k-nasa 61b7a09c70 Fix type declaration 5 years ago
nasa 8932cecec7
Update src/stream/stream/flatten.rs
Co-Authored-By: Taiki Endo <te316e89@gmail.com>
5 years ago
nasa bf3508ffb2
Update src/stream/stream/flatten.rs
Co-Authored-By: Taiki Endo <te316e89@gmail.com>
5 years ago
nasa 6168952d6f
Update src/stream/stream/flatten.rs
Co-Authored-By: Taiki Endo <te316e89@gmail.com>
5 years ago
nasa b7b5df13aa
Update src/stream/stream/flatten.rs
Co-Authored-By: Taiki Endo <te316e89@gmail.com>
5 years ago
nasa 7ce721f562
Update src/lib.rs
Co-Authored-By: Taiki Endo <te316e89@gmail.com>
5 years ago
k-nasa b66ffa670e update recursion_limit 5 years ago
k-nasa 0c5abee284 to unstable stream::flat_map, stream::flatten 5 years ago
k-nasa 001368d3df $cargo fmt 5 years ago
k-nasa 00e7e58bf3 fix type def 5 years ago
k-nasa 271b6f4a1c fix: Using pin_project! 5 years ago
k-nasa 3297a0f327 Merge branch 'master' into add_stream_flatten 5 years ago
k-nasa 48b255897e Merge branch 'master' into add_stdin_lock 5 years ago
k-nasa feeb3c10df fix: Remove Pin API related unsafe code 5 years ago
k-nasa b17af61367 Merge branch 'master' into add_stream_timeout 5 years ago
k-nasa d97b3dfdf3 fix: Remove Pin API related unsafe code 5 years ago
k-nasa 5c9cfb4fe8 Merge branch 'master' into add_future_delay 5 years ago
Wouter Geraedts 1fd05a157f Reset delay to prevent poll after ready 5 years ago
Wouter Geraedts 1c843a8124 Re-implemented Throttle to keep last value in memory 5 years ago
Stjepan Glavina b2fe91385b
Add channel behind unstable feature flag (#380)
* Add channel behind unstable feature flag

* Don't check tests without unstable feature flag

* Fix typos

* Remove useless attribute
5 years ago
Taiki Endo 2abf5ca891
Deny warnings on CI (#378)
* Deny warnings on CI

* Fix some clippy warnings
5 years ago
yjhmelody f5a0a0ba86 fmt 5 years ago
yjhmelody d6f940110b update doc 5 years ago
yjhmelody 020eb85093 add stream::min_by_key method 5 years ago
Taiki Endo 944e43d4bf Remove Pin API related unsafe code by using pin-project-lite cra… (#381) 5 years ago
yjhmelody 4e5828e646 add stream::max_by method 5 years ago
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`.
5 years ago
Sunjay Varma 0d4a907335 Added Extend + FromStream for PathBuf 5 years ago
Johannes Weissmann 97094b2a1c remove Sized constraint 5 years ago
Wouter Geraedts ced5281b73 Merge remote-tracking branch 'upstream/master' into 342-stream-throttle 5 years ago
Johannes Weissmann a9a7bdc290 add stream::count 5 years ago
k-nasa 410d16eaf6 Add docs + To unstable feature 5 years ago
k-nasa 1c1e2230f3 Merge branch 'master' into add_stream_flatten 5 years ago
k-nasa 176359afae Add Stream::flatten 5 years ago
k-nasa 8138afbfad feat: Add Stream trait for Flatten 5 years ago
k-nasa cd862083a5 Add Flatten struct 5 years ago
k-nasa 2187a2a31d feat: Add Stream::flat_map 5 years ago
k-nasa 2dee289750 Add FlatMap struct 5 years ago
k-nasa bb1416420d feat: Add Stream trait for FlattenCompat 5 years ago
Stjepan Glavina 8bef2e9e95 Don't flush files if they weren't written to 5 years ago
Stjepan Glavina ec23632f3e
Cleanup: replace cfg-if with our macros (#361)
* Cleanup: replace cfg-if with our macros

* Prefix macros with cfg_

* Remove #[macro_export] from internal macros
5 years ago
k-nasa ec98b41c85 feat: Add FlattenCompat struct 5 years ago
Stjepan Glavina 46f0fb1c64
Make sure each invocation of block_on uses its own Parker (#358) 5 years ago
k-nasa f2bf01223c $cargo fmt 5 years ago
k-nasa 70e8476264 fix StdinLock doc test 5 years ago
k-nasa a5a00d7b14 feat: Add StdinLock struct 5 years ago
Wouter Geraedts a2393501c5 Implemented StreamExt::throttle 5 years ago
k-nasa b58bd8d725 Merge branch 'add_stream_timeout' of https://github.com/k-nasa/async-std into add_stream_timeout 5 years ago
k-nasa 0a4073449b doc: Add Stream::Timeout doc 5 years ago
k-nasa c3f6f969c5 fix: Rename TimeoutStream to Timeout 5 years ago
k-nasa 53fa132d13 fix type Declaration 5 years ago
k-nasa 9d55fff81d fix export FutureExt 5 years ago
nasa f1ed034600
Update src/stream/stream/mod.rs
Co-Authored-By: Yoshua Wuyts <yoshuawuyts+github@gmail.com>
5 years ago
Yoshua Wuyts 9ff0750d4d
Merge pull request #353 from async-rs/fix-printing
fix print macros
5 years ago
Yoshua Wuyts 4d34a15363
fix macros, take II
Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>
5 years ago
Yoshua Wuyts 822e4bc220
Merge branch 'master' into fs-stream-repeat-with 5 years ago
Yoshua Wuyts 6e0905d3ca correctly mark stream::Merge as unstable (#352)
Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>
5 years ago
k-nasa 10f32ca817 Fix TimeoutError 5 years ago
Johannes Weissmann aaa1b6ca39 add Stream::last (#347)
* add stream::LastFuture (not compiling)

Struggling with the associated type, pinning and how to move/copy
LastFuture.last.

* fix type signature -> still cannot assign

still problems assigning the new value to self.last

* remove unused bound

* add doctest

* unpin LastFuture.last

* RustFmt

* add static lifetime

* remove redundant lifetime
5 years ago
k-nasa 358d2bc038 Add import crate 5 years ago
Stjepan Glavina add6863185
Fix typos 5 years ago
k-nasa b251fc999a Move delay method to FutureExt::delay 5 years ago
Yoshua Wuyts faff1f7370 task docs (#346)
Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>
5 years ago
k-nasa 054f4fac74 feat: Add future::delay 5 years ago
k-nasa 7a87dea085 feat: Add Stream::timeout 5 years ago
k-nasa f00d32ee7d Add TimeoutStream struct 5 years ago
Yoshua Wuyts e986e7ba66
Merge pull request #345 from async-rs/io-docs
Io docs
5 years ago
Wouter Geraedts 6b00e5e66c Implemented StreamExt::try_fold (#344) 5 years ago
assemblaj 4b96ea1273 Adds Stream::cmp (#273)
* Adds cmp

* Fixes formatting

* cleans up examples

* attempts to fix rustdoc issue

* formats with cargo fmt

* Adds proper trait bounds for cmp
5 years ago
Yoshua Wuyts d250eee556
port the std::io docs to async_std::io
Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>
5 years ago