Added missing parameter. Removed double "the".

Author: horned-sphere

api/swimos_agent_protocol/src/model.rs

@@ -156,7 +156,7 @@ pub struct AdHocCommand<S, T> {
 
 impl<S, T> AdHocCommand<S, T> {
     /// # Arguments
-    /// * `address` - The target lane for the the command.
+    /// * `address` - The target lane for the command.
     /// * `command` - The body of the command message.
     /// * `overwrite_permitted` - Controls the behaviour of command handling in the case of back-pressure.
     /// If this is true, the command maybe be overwritten by a subsequent command to the same target (and so

api/swimos_form/src/lib.rs

@@ -20,7 +20,7 @@
 //! [`std::collections::HashMap`].
 //!
 //! A derivation macro is provided that can automatically generate implementations for straightforward
-//! struct and enum types. For instructions on how to use this, see the the [`Form`] trait or the SwimOS
+//! struct and enum types. For instructions on how to use this, see the [`Form`] trait or the SwimOS
 //! documentation.
 
 #![allow(clippy::match_wild_err_arm)]

api/swimos_form/src/structural/generic/coproduct.rs

@@ -45,7 +45,7 @@ impl Coproduct for CNil {
 }
 
 /// A non-empty coproduct. In general, we should have `T: Coproduct`, however, this makes it
-/// impossible to implement traits for general co-products due the the potentially unbounded
+/// impossible to implement traits for general co-products due potentially unbounded
 /// recursion.
 pub enum CCons<H, T> {
     Head(H),

api/swimos_form/src/structural/generic/header.rs

@@ -139,7 +139,7 @@ impl<T, S: AppendHeaders> HeaderWithBody<T, S> {
 }
 
 /// This trait allows all of the types in this crate to be used with a unified interface
-/// in the the macro-derived implementations.
+/// in the macro-derived implementations.
 pub trait AppendHeaders {
     /// The number of items that will be written into the attribute body.
     fn num_items(&self) -> usize;

api/swimos_model/src/value.rs

@@ -191,7 +191,7 @@ impl Display for ValueKind {
 }
 
 impl Value {
-    /// Checks if the a [`Value`] is coercible into the [`ValueKind`] provided.
+    /// Checks if the [`Value`] is coercible into the [`ValueKind`] provided.
     pub fn is_coercible_to(&self, kind: ValueKind) -> bool {
         match &self {
             Value::Int32Value(n) => match &kind {

docs/downlink.md

@@ -24,7 +24,7 @@ The common events shared by all downlinks are:
 2. `on_synced`: This is triggered when a consistent view of the state of the remote lane has been assembled in the
    downlink. It takes a reference to the state of the downlink as a parameter.
 3. `on_unlinked`: This is triggered when the link to the remote lane is closed. It takes no parameters.
-4. `on_failed`: This is triggered when the link the the remote lane fails with an error. It takes no parameters.
+4. `on_failed`: This is triggered when the link the remote lane fails with an error. It takes no parameters.
 
 As downlinks have a single type (whereas an agent can have multiple lanes with arbitrary types) it is not necessary to
 use a macro to assemble a downlink lifecycle implementation. Instead, builder types are provided to specify the event
@@ -149,7 +149,7 @@ Each time a value is received on the downlink, it will be set as the value of th
 Building a stateful downlink
 ----------------------------
 
-As with agent lifecycles, it is possible to add state the a downlink lifecycle. As an example, we can extend the
+As with agent lifecycles, it is possible to add state to a downlink lifecycle. As an example, we can extend the
 downlink lifecycle from the previous section to set the value of the `received` lane to be the _previous_ value that was
 received by the downlink.
 

runtime/swimos_runtime/src/agent/mod.rs

@@ -60,7 +60,7 @@ use self::{
     },
 };
 
-/// Describes the metrics the the agent runtime task reports as it runs. These are subscribed to by the
+/// Describes the metrics the agent runtime task reports as it runs. These are subscribed to by the
 /// introspection API to report on the internal state of server application.
 pub mod reporting;
 mod store;
@@ -137,6 +137,7 @@ impl DownlinkRequest {
     /// # Arguments
     ///
     /// * `remote` - An explicit host for the agent, if defined.
+    /// * `address` - The containing node URI a and name of the lane to link to.
     /// * `kind` - The kind of the downlink to open.
     /// * `options` - Configuration parameters for the downlink.
     /// * `promise` - A promise to be satisfied with a channel to the downlink.
@@ -597,7 +598,7 @@ impl AgentRouteChannels {
     }
 }
 
-/// The agent runtime task. This mediates between the the user defined agent state and event handlers
+/// The agent runtime task. This mediates between the user defined agent state and event handlers
 /// and the other entities within the Swim server application.
 pub struct AgentRouteTask<'a, A> {
     agent: &'a A,

runtime/swimos_runtime/src/lib.rs

@@ -16,7 +16,7 @@
 //!
 //! Tokio tasks describing the core IO loops for agents and downlinks. These tasks implement
 //! the Warp protocol only and are entirely decoupled from the state and user defined behaviour
-//! of the the agents/downlinks.
+//! of the agents/downlinks.
 
 use swimos_utilities::byte_channel::{ByteReader, ByteWriter};
 

server/swimos_agent_derive/src/lane_model_derive/model.rs

@@ -183,7 +183,7 @@ bitflags! {
     }
 }
 
-/// Description of an item (its name the the kind of the item, along with types).
+/// Description of an item (its name the kind of the item, along with types).
 #[derive(Clone)]
 pub struct ItemModel<'a> {
     pub name: &'a Ident,
@@ -227,7 +227,7 @@ impl<'a> ItemModel<'a> {
     }
 }
 
-/// Description of an lane (its name the the kind of the lane, along with types).
+/// Description of an lane (its name the kind of the lane, along with types).
 #[derive(Clone)]
 pub struct WarpLaneModel<'a> {
     pub name: &'a Ident,
@@ -236,7 +236,7 @@ pub struct WarpLaneModel<'a> {
     pub transform: NameTransform,
 }
 
-/// Description of an HTTP lane (its name the the kind of the lane, along with types).
+/// Description of an HTTP lane (its name the kind of the lane, along with types).
 #[derive(Clone)]
 pub struct HttpLaneModel<'a> {
     pub name: &'a Ident,

swimos/src/agent.rs

@@ -156,7 +156,7 @@ pub use swimos_agent_derive::{lifecycle, projections, AgentLaneModel};
 /// For [`crate::agent::lanes::HttpLane`], the constraints on the type parameters are determined by the
 /// codec that is selected for the lane (using the appropriate type parameter). By default, this is the
 /// [`crate::agent::lanes::http::DefaultCodec`]. This codec always requires that type parameters implement
-/// [`crate::form::Form`] and, if the 'json' feature is active, that the they are Serde serializable.
+/// [`crate::form::Form`] and, if the 'json' feature is active, that they are Serde serializable.
 ///
 /// The supported store types are:
 ///