Skip to content

Commit c6f8a2b

Browse files
author
phil3k3
committed
Tests compile
1 parent 92fe060 commit c6f8a2b

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

cqrs-example-client/src/main.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -126,7 +126,7 @@ async fn main() -> io::Result<()> {
126126
client: Mutex::new(
127127
CommandServiceClient::new(
128128
&settings2.get_string("service_id").unwrap(),
129-
Arc::new(create_channel),
129+
Arc::new(Mutex::new(Some(Box::new(create_channel)))),
130130
Box::new(kafka_command_channel)
131131
)
132132
)

0 commit comments

Comments
 (0)