Format

Author: SirCipher

server/swim_agent/src/lanes/join/map/mod.rs

@@ -53,15 +53,15 @@ mod tests;
 pub use downlink::{AfterClosed, JoinMapLaneUpdate};
 pub use init::LifecycleInitializer;
 
-/// Model of a join map lane. This is conceptually similar to a [`super::super::MapLane`] only, rather than 
+/// Model of a join map lane. This is conceptually similar to a [`super::super::MapLane`] only, rather than
 /// the state being modified directly, it is populated through a series of map downlinks Each map downlink is
 /// identified by a link key of type `L`.
-/// 
+///
 /// Each entry in the map is 'owned' by the link that most recently updated it. When a 'clear' message is
 /// received on a link, all keys owned by that link will be removed from the map. In all other respects,
 /// it behaves as a read only map lane, having the same set of event handlers.
-/// 
-/// Join lanes provide views of the state of other remote lanes and so do not persist their state and are 
+///
+/// Join lanes provide views of the state of other remote lanes and so do not persist their state and are
 /// always considered to be transient.
 #[derive(Debug)]
 pub struct JoinMapLane<L, K, V> {

server/swim_agent/src/lanes/join/value/mod.rs

@@ -54,11 +54,11 @@ pub use downlink::{AfterClosed, JoinValueLaneUpdate};
 pub use init::LifecycleInitializer;
 
 /// Model of a join value lane. This is conceptually similar to a [`super::super::MapLane`] only, rather
-/// than the state being modified directly, it is populated through a series of downlinks associated with 
+/// than the state being modified directly, it is populated through a series of downlinks associated with
 /// each key. Hence it maintains a view of the state of a number of remote values as a single map. In all
 /// other respects, it behaves as a read only map lane, having the same event handlers.
-/// 
-/// Join lanes provide views of the state of other remote lanes and so do not persist their state and are 
+///
+/// Join lanes provide views of the state of other remote lanes and so do not persist their state and are
 /// always considered to be transient.
 #[derive(Debug)]
 pub struct JoinValueLane<K, V> {

swim/tests/deriveagentlanemodel.rs

@@ -393,6 +393,7 @@ fn multiple_lanes() {
         eighth: DemandMapLane<i32, i32>,
         ninth: SimpleHttpLane<i32>,
         tenth: JoinMapLane<i32, i32, i32>,
+        eleventh: SupplyLane<i32>,
     }
 
     check_agent::<MultipleLanes>(vec![
@@ -401,15 +402,12 @@ fn multiple_lanes() {
         persistent_lane(2, "third", WarpLaneKind::Value),
         persistent_lane(3, "fourth", WarpLaneKind::Map),
         transient_lane(4, "fifth", WarpLaneKind::Command),
-        persistent_lane(5, "sixth", WarpLaneKind::JoinValue),
+        transient_lane(5, "sixth", WarpLaneKind::JoinValue),
         transient_lane(6, "seventh", WarpLaneKind::Demand),
-        persistent_lane(1, "second", WarpLaneKind::Map),
-        persistent_lane(3, "fourth", WarpLaneKind::Map),
-        persistent_lane(5, "sixth", WarpLaneKind::JoinValue),
         transient_lane(7, "eighth", WarpLaneKind::DemandMap),
         http_lane(8, "ninth"),
         transient_lane(9, "tenth", WarpLaneKind::JoinMap),
-        transient_lane(9, "tenth", WarpLaneKind::Supply),
+        transient_lane(10, "eleventh", WarpLaneKind::Supply),
     ]);
 }