File tree Expand file tree Collapse file tree 1 file changed +3
-6
lines changed Expand file tree Collapse file tree 1 file changed +3
-6
lines changed Original file line number Diff line number Diff line change @@ -121,7 +121,7 @@ pub fn start_bridge_loop(
121
121
let mut tokio_builder = tokio:: runtime:: Builder :: new_multi_thread ( ) ;
122
122
tokio_builder. enable_all ( ) . thread_name ( "core" ) ;
123
123
let core_runtime =
124
- CoreRuntime :: new ( telemetry_options, tokio_builder) . expect ( "Failed to create CoreRuntime" ) ;
124
+ Arc :: new ( CoreRuntime :: new ( telemetry_options, tokio_builder) . expect ( "Failed to create CoreRuntime" ) ) ;
125
125
126
126
core_runtime. tokio_handle ( ) . block_on ( async {
127
127
loop {
@@ -144,14 +144,11 @@ pub fn start_bridge_loop(
144
144
headers,
145
145
callback,
146
146
} => {
147
- // `metrics_meter` can be None here since we don't use the returned client
148
- // directly at the moment, when we repurpose the client to be used by a Worker,
149
- // `init_worker` will attach the correct metrics meter for us.
147
+ let runtime_clone = core_runtime. clone ( ) ;
150
148
core_runtime. tokio_handle ( ) . spawn ( async move {
151
- let metrics_meter = None ;
152
149
match options
153
150
. connect_no_namespace (
154
- metrics_meter ,
151
+ runtime_clone . metric_meter ( ) . as_deref ( ) ,
155
152
headers. map ( |h| Arc :: new ( RwLock :: new ( h) ) ) ,
156
153
)
157
154
. await
You can’t perform that action at this time.
0 commit comments