Skip to content

Commit e4c96bc

Browse files
committed
rch::watch: avoid initial changed state on watch channel
1 parent 1a733e8 commit e4c96bc

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

remoc/src/rch/watch/receiver.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -265,7 +265,8 @@ where
265265
S: serde::Serializer,
266266
{
267267
// Prepare channel for takeover.
268-
let rx = self.rx.clone();
268+
let mut rx = self.rx.clone();
269+
let data = rx.borrow_and_update().clone();
269270
let remote_send_err_tx = self.remote_send_err_tx.clone();
270271

271272
let port = PortSerializer::connect(|connect| {
@@ -285,7 +286,6 @@ where
285286
})?;
286287

287288
// Encode chmux port number in transport type and serialize it.
288-
let data = self.rx.borrow().clone();
289289
let transported = TransportedReceiver::<T, Codec> {
290290
port,
291291
data,

0 commit comments

Comments
 (0)