refactor(cbus):
- now `LCPipe::push_message` signature requires &mut self, cause write into `LCPipe` is not thread safe - remove `oneshot::channel_on_pipe` function - create a unique `LCPipe` instance for each `unbounded::Sender` instead of share single `LCPipe` by arc (also related to #156) - use a weak reference on `unbounded::Waker` in `unbounded::Sender` to prevent situation when waker dropped in non cord thread
Showing
- CHANGELOG.md 4 additions, 0 deletionsCHANGELOG.md
- tarantool/src/cbus/mod.rs 2 additions, 6 deletionstarantool/src/cbus/mod.rs
- tarantool/src/cbus/oneshot.rs 15 additions, 41 deletionstarantool/src/cbus/oneshot.rs
- tarantool/src/cbus/unbounded.rs 63 additions, 39 deletionstarantool/src/cbus/unbounded.rs
Loading
Please register or sign in to comment