Comments (10)
Apologies, it appears like I had not pushed the change at the time! I am investigating the missing recv end at the moment, but the panic is gone for me.
from flume.
I encountered this too and it's fixed on #40
from flume.
I think the fix was just to remove the assertion since after some investigation it doesn't seem to be a valid assertion with the way we do async anyways.
from flume.
I tested #40 on https://github.com/hatoo/flume-panic/tree/pr-40
flume = { git = "https://github.com/Restioson/flume.git", branch = "async-edits" }
And got another panic and prints recv end
on debug build.
And freezes and prints send end
on release build.
I've found that it's OK if change send_async
to send
.
Is send_async
has same kind issue?
from flume.
Okay, I believe I found the issue. I have pushed a fix - 6f318d5. The testbed now works for me - could you cargo update
and give it a try on your end?
from flume.
I've confirmed it works on 6f318d5.
Thank you!
from flume.
Thanks! If it's alright with you, could I integrate your example as above into the test suite?
from flume.
Yes of course!
from flume.
I've just published 0.9.0
which includes these fixes.
from flume.
Thanks. It worked!
from flume.
Related Issues (20)
- Awaiting disconnection of Receiver or Sender HOT 2
- Race condition in the async code when sender drops too quickly HOT 1
- `flume::Sender<T>` stops to send messages to `flume::Receiver<T>` when passed through `.await` point HOT 2
- The last messge won't be triggered in async code block. HOT 8
- `async`: `send_timeout` & `send_deadline` HOT 3
- Question: Fairness when multiple receivers are doing work-stealing HOT 2
- Document features HOT 1
- Generic over backing storage / statically allocated bounded channels HOT 1
- MPMC Not working or no Broadcasting HOT 3
- async selector HOT 2
- Semantic violation that involves rendezvous channel and selector HOT 4
- Lost message when selecing on MPMC in loop from multiple threads HOT 2
- Senders and receivers are both unusable in browser main thread in WASM
- Do we need to add a timeout for `recv_async`? HOT 1
- `SendFut::poll` should return `Poll::Pending` for rendezvous channels when no item is queued
- recv on an empty unbounded channel keeps the task busy. HOT 1
- Add a `force_send()` function to `flume::Sender`?
- Resize the capacity of bounded channels HOT 1
- Clarify behavior rendezvous channels HOT 10
- Memory leak in unbounded channels HOT 1
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from flume.