Remove unnecessary event loop proxy Mutex
I am not sure why I had to use it in the first place...
This commit is contained in:
parent
c688452d7b
commit
65ff3744a0
@ -469,17 +469,12 @@ impl Subscriptions {
|
|||||||
futures::channel::mpsc::channel(100);
|
futures::channel::mpsc::channel(100);
|
||||||
|
|
||||||
let stream = recipe.stream(event_receiver);
|
let stream = recipe.stream(event_receiver);
|
||||||
|
let proxy = proxy.clone();
|
||||||
// TODO: Find out how to avoid using a mutex here
|
|
||||||
let proxy =
|
|
||||||
std::sync::Arc::new(std::sync::Mutex::new(proxy.clone()));
|
|
||||||
|
|
||||||
let future = futures::future::select(
|
let future = futures::future::select(
|
||||||
cancelled,
|
cancelled,
|
||||||
stream.for_each(move |message| {
|
stream.for_each(move |message| {
|
||||||
proxy
|
proxy
|
||||||
.lock()
|
|
||||||
.expect("Acquire event loop proxy lock")
|
|
||||||
.send_event(message)
|
.send_event(message)
|
||||||
.expect("Send subscription result to event loop");
|
.expect("Send subscription result to event loop");
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user