File tree 3 files changed +3
-3
lines changed
3 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -157,7 +157,7 @@ impl ComputeApi {
157
157
pub fn listen ( & self , endpoint : quinn:: Endpoint ) -> anyhow:: Result < AbortOnDropHandle < ( ) > > {
158
158
match & self . inner {
159
159
ServiceSender :: Local ( local, _) => {
160
- let local = LocalMpscChannel :: from ( local. clone ( ) ) ;
160
+ let local = local. clone ( ) ;
161
161
let handler: Handler < ComputeProtocol > = Arc :: new ( move |msg, rx : RemoteRead , tx| {
162
162
let local = local. clone ( ) ;
163
163
Box :: pin ( match msg {
Original file line number Diff line number Diff line change @@ -116,7 +116,7 @@ impl StorageApi {
116
116
pub fn listen ( & self , endpoint : quinn:: Endpoint ) -> anyhow:: Result < AbortOnDropHandle < ( ) > > {
117
117
match & self . inner {
118
118
ServiceSender :: Local ( local, _) => {
119
- let local = LocalMpscChannel :: from ( local. clone ( ) ) ;
119
+ let local = local. clone ( ) ;
120
120
let handler: Handler < StorageProtocol > = Arc :: new ( move |msg, _, tx| {
121
121
let local = local. clone ( ) ;
122
122
Box :: pin ( match msg {
Original file line number Diff line number Diff line change @@ -128,7 +128,7 @@ impl StorageApi {
128
128
pub fn listen ( & self , endpoint : quinn:: Endpoint ) -> anyhow:: Result < AbortOnDropHandle < ( ) > > {
129
129
match & self . inner {
130
130
ServiceSender :: Local ( local, _) => {
131
- let local = LocalMpscChannel :: from ( local. clone ( ) ) ;
131
+ let local = local. clone ( ) ;
132
132
let handler: Handler < StorageProtocol > = Arc :: new ( move |msg, _rx, tx| {
133
133
let local = local. clone ( ) ;
134
134
Box :: pin ( match msg {
You can’t perform that action at this time.
0 commit comments