Add missing module docs headers

async-nats/src/jetstream/consumer/mod.rs

@@ -11,7 +11,7 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 //
-//! Push and [Pull][PullConsumer] [Consumer] API.
+//! Push and Pull [Consumer] API.
 
 pub mod pull;
 pub mod push;

async-nats/src/jetstream/message.rs

@@ -11,6 +11,7 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
+//! A wrapped `crate::Message` with `JetStream` related methods.
 use super::context::Context;
 use crate::Error;
 

async-nats/src/jetstream/response.rs

@@ -11,6 +11,8 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
+//! A low level `JetStream` responses.
+
 use serde::Deserialize;
 
 /// An error description returned in a response to a jetstream request.

async-nats/src/message.rs

@@ -11,6 +11,7 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
+//! A Core NATS message.
 use crate::header::HeaderMap;
 use crate::status::StatusCode;
 use bytes::Bytes;

async-nats/src/options.rs

@@ -614,8 +614,8 @@ impl<A, T> fmt::Debug for CallbackArg1<A, T> {
     }
 }
 
-/// Error report from signing callback
-// this was needed because std::io::Error isn't Send
+/// Error report from signing callback.
+// This was needed because std::io::Error isn't Send.
 #[derive(Clone)]
 pub struct AuthError(String);
 

async-nats/src/status.rs

@@ -11,6 +11,8 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
+//! NATS status codes.
+
 // Heavily borrowed from the http crate, would re-export since it is already a dependency
 // but we have our own range of constants.
 use std::convert::TryFrom;