Skip to content

Commit 68f2a6d

Browse files
Bobfacetomusdrw
andauthored
Use write_all in IPC transport (#648)
Co-authored-by: Tomasz Drwięga <[email protected]>
1 parent eadfdd8 commit 68f2a6d

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/transports/ipc.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -193,7 +193,7 @@ async fn run_server(unix_stream: UnixStream, messages_rx: UnboundedReceiverStrea
193193
}
194194

195195
let bytes = helpers::to_string(&rpc::Request::Single(rpc_call)).into_bytes();
196-
if let Err(err) = socket_writer.write(&bytes).await {
196+
if let Err(err) = socket_writer.write_all(&bytes).await {
197197
pending_response_txs.remove(&request_id);
198198
log::error!("IPC write error: {:?}", err);
199199
}
@@ -213,7 +213,7 @@ async fn run_server(unix_stream: UnixStream, messages_rx: UnboundedReceiverStrea
213213

214214
let bytes = helpers::to_string(&rpc::Request::Batch(rpc_calls)).into_bytes();
215215

216-
if let Err(err) = socket_writer.write(&bytes).await {
216+
if let Err(err) = socket_writer.write_all(&bytes).await {
217217
log::error!("IPC write error: {:?}", err);
218218
for request_id in request_ids {
219219
pending_response_txs.remove(&request_id);

0 commit comments

Comments
 (0)