Skip to content

Commit

Permalink
Merge pull request #228 from UiPath/fix-writes-on-shutdown
Browse files Browse the repository at this point in the history
send all pending responses before shutting down
  • Loading branch information
lifupan authored May 11, 2024
2 parents 6cf4d5b + 123183a commit 152ac12
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion src/asynchronous/server.rs
Original file line number Diff line number Diff line change
Expand Up @@ -327,13 +327,14 @@ impl Builder for ServerBuilder {
server_shutdown: self.shutdown_waiter.clone(),
handler_shutdown: disconnect_notifier,
},
ServerWriter { rx },
ServerWriter { rx, _server_shutdown: self.shutdown_waiter.clone() },
)
}
}

struct ServerWriter {
rx: MessageReceiver,
_server_shutdown: shutdown::Waiter
}

#[async_trait]
Expand Down

0 comments on commit 152ac12

Please sign in to comment.