Skip to content

Commit efe0cc4

Browse files
committed
Address PR comments.
1 parent 372a94c commit efe0cc4

File tree

2 files changed

+10
-4
lines changed
  • server/swimos_agent/src/lanes/join

2 files changed

+10
-4
lines changed

server/swimos_agent/src/lanes/join/map/downlink/mod.rs

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -660,9 +660,9 @@ where
660660
let lane = (projection)(context);
661661
let name = context.item_name(lane.id());
662662
f.debug_struct("AfterClosed")
663+
.field("state", &"Cleanup")
663664
.field("id", &lane.id())
664665
.field("lane_name", &name.as_ref().map(|s| s.as_ref()))
665-
.field("state", &"Cleanup")
666666
.field("address", address)
667667
.field("response", response)
668668
.finish()
@@ -672,7 +672,10 @@ where
672672
.field("state", &"Restarting")
673673
.field("handler", &Described::new(context, handler))
674674
.finish(),
675-
AfterClosed::Done => f.debug_tuple("AfterClosed").field(&"<<CONSUMED>>").finish(),
675+
AfterClosed::Done => f
676+
.debug_struct("AfterClosed")
677+
.field("state", &"Done")
678+
.finish(),
676679
}
677680
}
678681
}

server/swimos_agent/src/lanes/join/value/downlink/mod.rs

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -370,9 +370,9 @@ where
370370
let lane = (projection)(context);
371371
let name = context.item_name(lane.id());
372372
f.debug_struct("AfterClosed")
373+
.field("state", &"Cleanup")
373374
.field("id", &lane.id())
374375
.field("lane_name", &name.as_ref().map(|s| s.as_ref()))
375-
.field("state", &"Cleanup")
376376
.field("address", address)
377377
.field("response", response)
378378
.finish()
@@ -382,7 +382,10 @@ where
382382
.field("state", &"Restarting")
383383
.field("handler", &Described::new(context, handler))
384384
.finish(),
385-
AfterClosed::Done => f.debug_tuple("AfterClosed").field(&"<<CONSUMED>>").finish(),
385+
AfterClosed::Done => f
386+
.debug_struct("AfterClosed")
387+
.field("state", &"Done")
388+
.finish(),
386389
}
387390
}
388391
}

0 commit comments

Comments
 (0)