File tree Expand file tree Collapse file tree
crates/core/src/subscription Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -534,9 +534,9 @@ impl SubscriptionManager {
534534 /// that the [`SendWorker`] should also add this client.
535535 ///
536536 /// Horrible signature to enable split borrows on [`Self`].
537- fn get_or_make_client_info_and_inform_send_worker < ' clients , ' send_worker_tx > (
537+ fn get_or_make_client_info_and_inform_send_worker < ' clients > (
538538 clients : & ' clients mut HashMap < ClientId , ClientInfo > ,
539- send_worker_tx : & ' send_worker_tx mut mpsc:: UnboundedSender < SendWorkerMessage > ,
539+ send_worker_tx : & mut mpsc:: UnboundedSender < SendWorkerMessage > ,
540540 client_id : ClientId ,
541541 outbound_ref : Client ,
542542 ) -> & ' clients mut ClientInfo {
@@ -1126,10 +1126,6 @@ struct SendWorkerClient {
11261126/// into `DbUpdate`s and then sends them to the clients' WebSocket workers.
11271127///
11281128/// See comment on the `send_worker_tx` field in [`SubscriptionManager`] for motivation.
1129- ///
1130-
1131- ///
1132-
11331129struct SendWorker {
11341130 /// Receiver end of the [`SubscriptionManager`]'s `send_worker_tx` channel.
11351131 rx : mpsc:: UnboundedReceiver < SendWorkerMessage > ,
You can’t perform that action at this time.
0 commit comments