Skip to content

Commit bf055af

Browse files
committed
FIX: CI Tests to ensure clear pass
1 parent ac3ca9b commit bf055af

File tree

4 files changed

+15
-6
lines changed

4 files changed

+15
-6
lines changed

.vscode/settings.json

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
{
22
"cSpell.words": [
3+
"contrib",
34
"rustdoc",
45
"Struct"
56
]

Cargo.toml

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,9 @@ serde = { version = "1.0.130", features = ["derive"] }
1818
serde_json = "1.0.68"
1919
lambda_runtime = "0.4.1"
2020

21+
[dev-dependencies]
22+
tokio = "1"
23+
2124
[package.metadata.docs.rs]
2225
all-features = true
2326
rustdoc-args = ["--cfg", "docsrs"]

src/domain.rs

Lines changed: 9 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -42,16 +42,21 @@ impl SqsEvent {
4242
///
4343
/// # Example
4444
/// ``` no_run
45+
/// # type MyType = Vec<String>;
46+
/// # use lambda_sqs::{SqsEvent, Context};
47+
/// #
48+
/// # fn handler(sqs_events:SqsEvent, c: Context) {
4549
/// let my_events: MyType = sqs_events.into_t();
50+
/// # }
4651
/// ```
4752
pub fn into_t<T>(self) -> Vec<T>
4853
where
49-
T: DeserializeOwned + Default,
54+
T: DeserializeOwned + Default,
5055
{
5156
self.records
52-
.into_iter()
53-
.map(move |message| serde_json::from_str(&message.as_string()).unwrap_or_default())
54-
.collect()
57+
.into_iter()
58+
.map(move |message| serde_json::from_str(&message.as_string()).unwrap_or_default())
59+
.collect()
5560
}
5661
}
5762

src/lib.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616
//!
1717
//! # Example
1818
//! ```no_run
19-
//! use your_module::YourStruct;
19+
//! # type YourStruct = String;
2020
//! use lambda_sqs::{handler_fn, Context, Error};
2121
//! use lambda_sqs::SqsEvent;
2222
//!
@@ -27,7 +27,7 @@
2727
//! Ok(())
2828
//! }
2929
//!
30-
//! pub async fn my_handler(e: SqsEvent, c: Context) -> Result<(), Error> {
30+
//! async fn my_handler(e: SqsEvent, c: Context) -> Result<(), Error> {
3131
//! let events: Vec<YourStruct> = e.into_t();
3232
//!# // Process events
3333
//!# Ok(())

0 commit comments

Comments
 (0)