Yoshua Wuyts
|
693a7257b8
|
Merge pull request #538 from k-nasa/stream_by_ref
Add stream by_ref
|
2019-11-15 17:14:17 +01:00 |
|
k-nasa
|
df92c63337
|
fix: Add unstable features
|
2019-11-16 00:29:54 +09:00 |
|
k-nasa
|
31cf932d80
|
wip: Add stream unzip
|
2019-11-16 00:24:59 +09:00 |
|
Yoshua Wuyts
|
3c6d41ccb4
|
Merge pull request #541 from yjhmelody/stream-partition
add stream-partition
|
2019-11-15 14:27:42 +01:00 |
|
yjh
|
74caed2d4b
|
Update src/io/seek/mod.rs
Co-Authored-By: Taiki Endo <te316e89@gmail.com>
|
2019-11-15 18:22:06 +08:00 |
|
yjhmelody
|
76ec9c4563
|
update doc url
|
2019-11-15 14:33:34 +08:00 |
|
yjhmelody
|
d76b32e6d4
|
make it unstable and fix trait bound
|
2019-11-15 14:23:34 +08:00 |
|
yjhmelody
|
11268a80fb
|
add stream-partition
|
2019-11-15 12:28:03 +08:00 |
|
Yoshua Wuyts
|
c4ba11ff95
|
Merge pull request #535 from async-rs/docs-sender-recv
backlink channel types
|
2019-11-15 03:35:43 +01:00 |
|
k-nasa
|
de67bf0fd4
|
feat: Add stream by_ref
|
2019-11-15 11:17:39 +09:00 |
|
Yoshua Wuyts
|
30ff7b09b6
|
mark Stream::count as unstable
Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>
|
2019-11-14 22:45:46 +01:00 |
|
Yoshua Wuyts
|
c58747b5fc
|
Merge pull request #368 from starsheriff/stream_count
add stream::count
|
2019-11-14 22:40:45 +01:00 |
|
Yoshua Wuyts
|
31f129ebe7
|
backlink channel types
Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>
|
2019-11-14 22:37:04 +01:00 |
|
Felipe Sere
|
64216b8e6b
|
Take a normal closure, not an async one
|
2019-11-14 21:49:24 +01:00 |
|
Felipe Sere
|
786a52a09d
|
Slight miss-merge
|
2019-11-14 21:37:51 +01:00 |
|
Felipe Sere
|
f14b37ff17
|
Remoe the T: Copy bound on the item
|
2019-11-14 21:35:38 +01:00 |
|
Felipe Sere
|
7677e9a3df
|
Make the closure take a borrow to the value
|
2019-11-14 21:35:38 +01:00 |
|
Felipe Sere
|
bfb42b432e
|
Rearrange docs to match 'repeat'
|
2019-11-14 21:35:38 +01:00 |
|
Felipe Sere
|
4c09cdbeac
|
Mark successors as unstable
|
2019-11-14 21:35:38 +01:00 |
|
Felipe Sere
|
243cdd7ff1
|
Slight miss-merge
|
2019-11-14 21:35:19 +01:00 |
|
Felipe Sere
|
a257b7018c
|
Rename some variables to match iter
|
2019-11-14 21:35:19 +01:00 |
|
Felipe Sere
|
af928163e4
|
Got further! Thx Josh!
|
2019-11-14 21:35:19 +01:00 |
|
Felipe Sere
|
8d97e0f974
|
Only produes empty value if next is ever a 'None'
|
2019-11-14 21:35:19 +01:00 |
|
Felipe Sere
|
266754897e
|
Rename the module to 'successors'
|
2019-11-14 21:35:19 +01:00 |
|
Felipe Sere
|
554d5cfbc1
|
Slight renamings
|
2019-11-14 21:34:57 +01:00 |
|
Felipe Sere
|
8b662b659d
|
Run rustfmt
|
2019-11-14 21:34:19 +01:00 |
|
Felipe Sere
|
95a3e53fcd
|
Only use the Option of the future to decide to construct a new one
|
2019-11-14 21:33:45 +01:00 |
|
Felipe Sere
|
02b261de10
|
It compiles! Store the future and poll it instead of creating multiple new ones
|
2019-11-14 21:33:45 +01:00 |
|
Felipe Sere
|
fe3c9ef626
|
First attempt at successor
|
2019-11-14 21:33:45 +01:00 |
|
Yoshua Wuyts
|
4e1d79adb1
|
Merge pull request #524 from yjhmelody/stream-max
Add Stream max
|
2019-11-14 21:28:36 +01:00 |
|
Yoshua Wuyts
|
338273eb18
|
Merge pull request #356 from Wassasin/342-stream-throttle
Implemented StreamExt::throttle
|
2019-11-14 21:25:34 +01:00 |
|
Wouter Geraedts
|
dda65cbff0
|
Start throttle measurement before initialisation
|
2019-11-14 11:29:49 +01:00 |
|
Johannes Weissmann
|
9ebe41f2d6
|
Update src/stream/stream/mod.rs
Co-Authored-By: nasa <htilcs1115@gmail.com>
|
2019-11-14 10:34:09 +01:00 |
|
Wouter Geraedts
|
90c67c223a
|
Decreased throttle test time to original values; only test lower bound
|
2019-11-14 10:26:56 +01:00 |
|
Stjepan Glavina
|
0c2282ffdc
|
Optimization: a slot for the next task to run (#529)
* Optimization: a slot for the next task to run
* Only notify workers when a task is pushed into a queue
|
2019-11-13 20:32:37 +01:00 |
|
yjhmelody
|
5adb112a00
|
export IntoInnerError for io
|
2019-11-13 13:52:16 +08:00 |
|
yjhmelody
|
9d634cb2a7
|
refactor io dir to be same with std
|
2019-11-13 12:42:59 +08:00 |
|
yjhmelody
|
879af6dc85
|
Add Stream max
|
2019-11-13 10:50:09 +08:00 |
|
Yoshua Wuyts
|
2dfdc1c482
|
polish lib.rs examples
Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>
|
2019-11-12 23:10:23 +01:00 |
|
Grzegorz Gierlach
|
e442eba625
|
Cleaning up stream pinning.
|
2019-11-12 19:51:58 +01:00 |
|
Grzegorz Gierlach
|
f0875d2dca
|
Cleaning up stream pinning.
|
2019-11-12 19:34:08 +01:00 |
|
Devashish Dixit
|
f611ceccc8
|
Run cargo fmt for doc comments (#515)
|
2019-11-12 17:47:03 +01:00 |
|
Wouter Geraedts
|
c5b3a98e5b
|
Increased throttle test to 10x time
|
2019-11-12 16:22:25 +01:00 |
|
Wouter Geraedts
|
4ab7b213de
|
Updated example to be consistent; added timing measurements to throttle
|
2019-11-12 15:38:02 +01:00 |
|
Wouter Geraedts
|
6990c1403f
|
Reimplemented throttle to never drop Delay, added boolean flag
|
2019-11-12 15:07:20 +01:00 |
|
Wouter Geraedts
|
77a1849303
|
Merge branch '342-stream-throttle' of github.com:Wassasin/async-std into 342-stream-throttle
|
2019-11-12 15:03:54 +01:00 |
|
Wouter Geraedts
|
a722de1a10
|
Merge remote-tracking branch 'upstream/master' into 342-stream-throttle
|
2019-11-12 14:51:24 +01:00 |
|
Wouter Geraedts
|
88cbf2c119
|
Change throttle test to run in milliseconds
|
2019-11-12 14:51:11 +01:00 |
|
Wouter Geraedts
|
6f6d5e9d20
|
Updated throttle fn comments.
Co-Authored-By: Yoshua Wuyts <yoshuawuyts+github@gmail.com>
|
2019-11-12 14:35:03 +01:00 |
|
Wouter Geraedts
|
7c7386735e
|
Wrap around throttle comment
Co-Authored-By: Yoshua Wuyts <yoshuawuyts+github@gmail.com>
|
2019-11-12 14:34:31 +01:00 |
|
Yoshua Wuyts
|
0d5c7a217f
|
stabilize task::yield_now
Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>
|
2019-11-12 02:10:55 +01:00 |
|
Stjepan Glavina
|
1a50ffd144
|
Delete unused import
|
2019-11-12 00:38:22 +01:00 |
|
Stjepan Glavina
|
21c5c48cb6
|
Lower the timeout to 1 second
|
2019-11-12 00:37:54 +01:00 |
|
Stjepan Glavina
|
6677d52c2d
|
Improve thread creating algorithm in spawn_blocking
|
2019-11-12 00:35:29 +01:00 |
|
Johannes Weissmann
|
37922408e5
|
use pin_project
|
2019-11-11 22:17:29 +01:00 |
|
Johannes Weissmann
|
7d2282dbd2
|
fix merge conflict
|
2019-11-11 22:11:06 +01:00 |
|
Johannes Weissmann
|
60f822bee5
|
Merge branch 'master' into stream_count
|
2019-11-11 22:06:09 +01:00 |
|
Yoshua Wuyts
|
4aa9928ece
|
v1.0.0
Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>
|
2019-11-11 16:13:22 +01:00 |
|
Stjepan Glavina
|
5438258cee
|
Remove unused import
|
2019-11-11 13:19:59 +01:00 |
|
Wouter Geraedts
|
ef958f0408
|
Use pin_project_lite instead for throttle
|
2019-11-11 13:09:41 +01:00 |
|
Stjepan Glavina
|
dc5d143c16
|
Merge branch 'master' into cleanup-stream
|
2019-11-11 13:08:38 +01:00 |
|
Stjepan Glavina
|
c2f750d288
|
Cleanup stream module
|
2019-11-11 13:07:29 +01:00 |
|
Wouter Geraedts
|
139a34b685
|
Make throttle an unstable feature
|
2019-11-11 12:26:32 +01:00 |
|
Wouter Geraedts
|
b591fc68bd
|
Changed semantics of throttle to non-dropping variant with backpressure
|
2019-11-11 12:17:00 +01:00 |
|
razican
|
5d558ca213
|
Fixed test, order is no longer guaranteed
|
2019-11-11 11:39:30 +01:00 |
|
razican
|
e48e463736
|
Duplicating code due to strange Rust error.
|
2019-11-11 11:26:40 +01:00 |
|
razican
|
0c37d4af10
|
Anonymous function to avoid type issues
|
2019-11-11 11:25:50 +01:00 |
|
Stjepan Glavina
|
352f18bc2a
|
Use async_std::sync::Arc in examples (#501)
|
2019-11-11 11:10:36 +01:00 |
|
razican
|
79bbf4938d
|
Randomize Stream::merge to improve the throughput. Implements #490.
|
2019-11-11 10:44:12 +01:00 |
|
Wouter Geraedts
|
14d7d3bf9c
|
Merge remote-tracking branch 'upstream/master' into 342-stream-throttle
|
2019-11-11 10:15:27 +01:00 |
|
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
|
2019-11-11 00:31:33 +01:00 |
|
Stjepan Glavina
|
122e87364b
|
Remove cache padding in channels
|
2019-11-09 23:08:31 +01:00 |
|
Stjepan Glavina
|
d4f38e783f
|
Cleanup future module
|
2019-11-09 17:26:19 +01:00 |
|
Yoshua Wuyts
|
96d3560742
|
remove future::*join macros (#492)
Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>
|
2019-11-09 17:02:48 +01:00 |
|
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
|
2019-11-09 17:02:17 +01:00 |
|
Stjepan Glavina
|
9e185f1c3e
|
Unstable feature: copy takes arguments by value (#471)
* Unstable feature: copy takes arguments by value
* Fix feature flags
|
2019-11-09 16:59:35 +01:00 |
|
Yoshua Wuyts
|
89d611628a
|
Merge pull request #483 from ryan-scott-dev/rscott/pathbuf_fromiter
Add FromIterator and Extend trait implementations for PathBuf
|
2019-11-09 13:03:28 +01:00 |
|
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()
|
2019-11-09 12:14:56 +01:00 |
|
Yoshua Wuyts
|
037119c0c0
|
Merge pull request #478 from portgasd666/master
Add Future::join and Future::try_join
|
2019-11-09 11:31:47 +01:00 |
|
Stjepan Glavina
|
548733e5d5
|
Cleanup stream traits (#487)
* Cleanup stream traits
* Fix docs
|
2019-11-09 11:22:09 +01:00 |
|
Abhishek C. Sharma
|
f04b6f6fe9
|
Change module level docs for future to refer to join and try_join functions instead of macros
|
2019-11-09 13:09:47 +05:30 |
|
Friedel Ziegelmayer
|
4a78f731b7
|
fix: stream::take_while (#485)
When the predicate is false, the stream should be ended.
|
2019-11-09 00:00:03 +01:00 |
|
Ryan Scott
|
8f3366072f
|
Add FromIterator and Extend trait implementations for PathBuf
|
2019-11-08 22:10:56 +11:00 |
|
laizy
|
fb19ebde17
|
add Sync constraint for RwLock to prevent memory unsafety (#479)
|
2019-11-08 08:56:55 +00:00 |
|
Abhishek C. Sharma
|
b14282457c
|
Add Future::join and Future::try_join
|
2019-11-08 11:29:39 +05:30 |
|
Stjepan Glavina
|
ab2f64cd84
|
Mark extend() as unstable
|
2019-11-08 02:38:49 +01:00 |
|
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
|
2019-11-07 23:56:58 +00:00 |
|
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
|
2019-11-07 23:39:54 +00:00 |
|
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>
|
2019-11-07 22:10:55 +00:00 |
|
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
|
2019-11-07 22:01:36 +00:00 |
|
Yoshua Wuyts
|
266e6326eb
|
document path submodule (#467)
Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>
|
2019-11-07 21:48:23 +00:00 |
|
Stjepan Glavina
|
f8e82564d9
|
Rename stream_extend to extend (#464)
* Rename stream_extend to extend
* Remove Extend from prelude
* Add stream::extend()
|
2019-11-07 21:46:58 +00:00 |
|
Abhishek C Sharma
|
eb1ef3f4e4
|
Minor documentation fix for race and try_race (#473)
|
2019-11-07 19:19:05 +00:00 |
|
Yoshua Wuyts
|
d0f1996759
|
Merge pull request #388 from felipesere/cycle
Implement stream::cycle(..)
|
2019-11-07 13:14:43 +01:00 |
|
Yoshua Wuyts
|
8a0e29473a
|
Merge pull request #446 from yjhmelody/stream-cloned
Add Stream cloned
|
2019-11-07 13:13:20 +01:00 |
|
Yoshua Wuyts
|
929027796e
|
hide future::Flatten
Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>
|
2019-11-07 03:06:38 +01:00 |
|
Yoshua Wuyts
|
9a8805678e
|
Merge pull request #443 from portgasd666/master
Added Future::flatten
|
2019-11-07 03:04:23 +01:00 |
|
Yoshua Wuyts
|
a064a5b13e
|
Merge pull request #459 from stjepang/expose-ext-traits
Expose extension traits in preludes
|
2019-11-07 02:48:50 +01:00 |
|
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
|
2019-11-06 20:20:27 +00:00 |
|
Stjepan Glavina
|
93b01e36ed
|
Clippy fixes (#462)
|
2019-11-06 19:29:17 +00:00 |
|