| .. |
|
mpsc
|
c444e50b8d
fix(mpsc): ensure un-received messages are dropped (#29)
|
%!s(int64=3) %!d(string=hai) anos |
|
thingbuf
|
23f4c96fa4
perf(mspc): replace bad VecDeque wait queue with intrusive list (#16)
|
%!s(int64=3) %!d(string=hai) anos |
|
util
|
5b17c184b0
feat(mpsc): add support for statically-allocated MPSC channels (#23)
|
%!s(int64=3) %!d(string=hai) anos |
|
wait
|
c444e50b8d
fix(mpsc): ensure un-received messages are dropped (#29)
|
%!s(int64=3) %!d(string=hai) anos |
|
lib.rs
|
c444e50b8d
fix(mpsc): ensure un-received messages are dropped (#29)
|
%!s(int64=3) %!d(string=hai) anos |
|
loom.rs
|
a2a52c933e
test(loom): fix missing `LOOM_LOG=trace` logs
|
%!s(int64=3) %!d(string=hai) anos |
|
macros.rs
|
c58c620096
fix(mpsc): fix a deadlock in async send_ref (#20)
|
%!s(int64=3) %!d(string=hai) anos |
|
mpsc.rs
|
5b17c184b0
feat(mpsc): add support for statically-allocated MPSC channels (#23)
|
%!s(int64=3) %!d(string=hai) anos |
|
static_thingbuf.rs
|
c444e50b8d
fix(mpsc): ensure un-received messages are dropped (#29)
|
%!s(int64=3) %!d(string=hai) anos |
|
stringbuf.rs
|
5e749ccc91
feat(mpsc): make errors more like other mpscs (#5)
|
%!s(int64=3) %!d(string=hai) anos |
|
thingbuf.rs
|
c444e50b8d
fix(mpsc): ensure un-received messages are dropped (#29)
|
%!s(int64=3) %!d(string=hai) anos |
|
util.rs
|
8c882b0f40
perf(mpsc): rewrite and optimize wait queue (#22)
|
%!s(int64=3) %!d(string=hai) anos |
|
wait.rs
|
8c882b0f40
perf(mpsc): rewrite and optimize wait queue (#22)
|
%!s(int64=3) %!d(string=hai) anos |
Eliza Weisman
c444e50b8d
fix(mpsc): ensure un-received messages are dropped (#29)