Jacob Rothstein
ae817ca1a2
don't poll the reader again after eof while waiting for the writer to flush
2022-06-02 15:32:40 -07:00
Marc-Antoine Perennou
8274995e70
stabilize new channels
...
Signed-off-by: Marc-Antoine Perennou <Marc-Antoine@Perennou.com>
2021-01-15 09:53:57 +01:00
dignifiedquire
8c5238743b
remove deprecated sync::channel
2021-01-13 11:20:29 +01:00
Marc-Antoine Perennou
8823c460fc
rand: update to 0.8
...
Signed-off-by: Marc-Antoine Perennou <Marc-Antoine@Perennou.com>
2020-12-23 22:12:19 +01:00
dignifiedquire
36366cd4d9
fix warnings
2020-12-01 15:25:11 +01:00
Friedel Ziegelmayer
e9cb238f49
fix wasm and nostd builds
...
Co-authored-by: Jacob Rothstein <hi@jbr.me>
2020-09-14 21:31:19 +02:00
Yoshua Wuyts
bd297473cc
Merge pull request #856 from yshui/master
...
Fix #855
2020-08-28 16:00:09 +02:00
Yoshua Wuyts
1319def758
Merge pull request #853 from r3v2d0g/udp-peek
...
Add peek{,from} methods to UdpSocket
2020-08-28 15:59:59 +02:00
Marc-Antoine Perennou
14d3e9865b
switch from tempdir to tempfile
...
Uses a more recent version of rand
Signed-off-by: Marc-Antoine Perennou <Marc-Antoine@Perennou.com>
2020-08-19 14:11:30 +02:00
Yuxuan Shui
59874d639c
tests: add test case for UnixStream::into_raw_fd
...
Signed-off-by: Yuxuan Shui <yshuiv7@gmail.com>
2020-08-18 11:10:20 +01:00
Matthieu Le brazidec (r3v2d0g)
47ce9a370c
Add peek{,from} methods to UdpSocket
2020-08-15 15:06:33 +02:00
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
dignifiedquire
8f17e9275b
test: try to stabilize CI
2020-06-26 12:48:23 +02:00
Friedel Ziegelmayer
5d55fa7a47
Merge pull request #701 from olegnn/flat_map_fixed
2020-06-18 12:18:47 +02:00
Afirez
9fa3ce3fd6
Add UdpSocket::PeerAddr #307
2020-06-14 18:45:27 +08:00
Oleg Nosov
df22d87d09
Removed unnecessary links + hotfix
2020-06-12 18:21:16 +03:00
Oleg Nosov
924e5a3f41
Merge remote-tracking branch 'origin/master' into flat_map_fixed
2020-06-12 18:13:01 +03:00
Friedel Ziegelmayer
e12cf80ab0
fix: allow for recursive block-on calls
...
Fixes #798,#795,#760
2020-06-04 13:19:03 +02:00
Friedel Ziegelmayer
2b6c7fedff
Merge pull request #772 from jbr/unixstream-clone
2020-05-13 18:03:47 +02:00
Azriel Hoh
baead51a28
Reduces duration in timeout test.
...
Tries to get CI to pass.
2020-05-13 10:38:40 +12:00
Jacob Rothstein
cd5e17fe87
make UnixStream Clone
2020-05-10 18:21:45 -07:00
Friedel Ziegelmayer
e4c4c93d29
Test and fix 32 bit targets
2020-05-07 23:20:44 +02:00
dignifiedquire
1214bc2dee
increase timeouts
2020-05-02 20:27:50 +02:00
dignifiedquire
e4df1405c1
feat: add basic wasm support
2020-05-02 20:27:50 +02:00
dignifiedquire
fd6ae40817
add timeout stress test
2020-05-02 20:27:50 +02:00
dignifiedquire
1308fbdf55
switch to smol instead of an internal runtime
2020-05-02 20:27:50 +02:00
Thayne McCombs
db438abb8f
Implement async_std::sync::Condvar ( #369 )
...
* Implement async_std::sync::Condvar
Part of #217
* More rigourous detection of notification for condvar
* Use state of Waker instead of AtomicUsize to keep track of if task was
notified.
* Add test for notify_all
* Implement wait_timeout_until
And add warnings about spurious wakeups to wait and wait_timeout
* Use WakerSet for Condvar
This should also address concerns about spurious wakeups.
* Add test for wait_timeout with no lock held
* Add comments describing AwaitNotify struct
And remove an unnneded comment in a Debug implementation
2020-04-12 13:35:18 +02:00
Yoshua Wuyts
19fd7a4084
fix channel tests
...
Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>
2020-03-15 23:53:03 +01:00
nasa
cc19592f80
Revert "Stabilize most stream method and remove unnecessary macros"
2020-03-12 18:34:09 +09:00
k-nasa
f33d7f40ab
fix test
2020-03-06 09:53:28 +09:00
k-nasa
ec4b09ecd0
fix test code
2020-03-05 18:47:53 +09:00
Oleg Nosov
68063adddf
Add link to tests
2020-02-08 16:22:11 +03:00
Oleg Nosov
32068942a6
Fixed flatten
2020-02-08 15:44:25 +03:00
Oleg Nosov
85c32ef9d2
Use assert
without if
-clause
2020-02-07 22:45:15 +03:00
Oleg Nosov
b68be72763
Use assert
instead of panic
2020-02-07 22:42:59 +03:00
Oleg Nosov
c80915e216
Dont spawn thread in tests
2020-02-07 22:22:38 +03:00
Oleg Nosov
303ac90b7c
Fixed flat_map
2020-02-07 22:12:42 +03:00
Stjepan Glavina
1d875836a2
Implement Clone for TcpStream ( #689 )
...
* Implement Clone for TcpStream
* Update examples
* Remove accidentally added examples
2020-01-28 18:14:16 +01:00
k-nasa
44e38eae59
fix open_file test code
2019-11-28 19:52:46 +09:00
Pascal Hertleif
56538ebd91
Improve verbose errors for socket addresses
...
Moves the point of adding error context to the net::addr module so that
we have access to the raw address input and can include it in the error
message.
2019-11-25 23:30:31 +01:00
Pascal Hertleif
e01f07d72a
Add context to more errors
...
cc #569
2019-11-21 00:27:47 +01:00
Pascal Hertleif
c704643296
Remove verbose-errors cargo feature
2019-11-19 13:15:48 +01:00
Pascal Hertleif
8ce3e78952
verbose errors feature
...
This adds a new "verbose-errors" feature flag to async-std that enables
wrapping certain errors in structures with more context. As an example,
we use it in `fs::File::{open,create}` to add the given path to the
error message (something that is lacking in std to annoyance of many).
2019-11-17 21:54:44 +01: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
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
2019-11-03 00:11:59 +01:00
Yoshua Wuyts
c413e717da
Merge pull request #429 from markhildreth/tcp_smoke_tests
...
Added TCP smoke tests against std Listener and Stream
2019-11-02 02:30:42 +01:00
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
2019-11-01 02:45:33 +01:00
Mark Hildreth
c6c2bfa456
Added TCP smoke tests against std Listener and Stream
2019-10-31 11:24:23 -04:00
k-nasa
7fe2a1bbce
fix clippy::cognitive_complexity
2019-10-27 20:32:22 +09:00
k-nasa
c9d958d309
$cargo fix -Z unstable-options --clippy --features unstable
2019-10-27 20:31:53 +09:00