Skip to content
This repository has been archived by the owner on Mar 21, 2024. It is now read-only.

Commit

Permalink
Clean up namings
Browse files Browse the repository at this point in the history
  • Loading branch information
afsalthaj committed Jan 29, 2024
1 parent a34226b commit 03dbde9
Showing 1 changed file with 7 additions and 7 deletions.
14 changes: 7 additions & 7 deletions src/clients/worker.rs
Original file line number Diff line number Diff line change
Expand Up @@ -305,13 +305,13 @@ impl<C: golem_client::api::WorkerClient + Sync + Send> WorkerClient for WorkerCl
}
});

let read_res = read.for_each(|message| async {
match message {
Err(e) => {
print!("Error reading message: {}", e);
let read_res = read.for_each(|message_or_error| async {
match message_or_error {
Err(error) => {
print!("Error reading message: {}", error);
}
Ok(msgg) => {
let msg = match msgg {
Ok(message) => {
let instance_connect_msg = match message {
Message::Text(str) => {
let parsed: serde_json::Result<InstanceConnectMessage> =
serde_json::from_str(&str);
Expand Down Expand Up @@ -347,7 +347,7 @@ impl<C: golem_client::api::WorkerClient + Sync + Send> WorkerClient for WorkerCl
}
};

match msg {
match instance_connect_msg {
None => {}
Some(msg) => match msg.event {
WorkerEvent::Stdout(StdOutLog { message }) => {
Expand Down

0 comments on commit 03dbde9

Please sign in to comment.