Skip to content

Commit

Permalink
cargo fmt
Browse files Browse the repository at this point in the history
  • Loading branch information
@Shahab96
Shahab96 committed Apr 11, 2024
1 parent 7c774e8 commit c9a651f
Show file tree
Hide file tree
Showing 3 changed files with 52 additions and 44 deletions.
7 changes: 3 additions & 4 deletions src/async_client.rs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -546,10 +546,9 @@ mod tests {
#[cfg(feature = "tls")]
#[tokio::test]
async fn ssl_verify() {
let client = super::Client::connect(
"memcache+tls://localhost:12350?ca_path=tests/assets/RUST_MEMCACHE_TEST_CERT.crt",
)
.unwrap();
let client =
super::Client::connect("memcache+tls://localhost:12350?ca_path=tests/assets/RUST_MEMCACHE_TEST_CERT.crt")
.unwrap();
assert!(client.version().await.unwrap()[0].1 != "");
}

Expand Down
5 changes: 4 additions & 1 deletion tests/test_ascii.rs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -63,7 +63,10 @@ async fn test_ascii() {
assert_eq!(value, Some("bar".into()));

client.set("ascii_baz", "qux", 0).await.unwrap();
let values: HashMap<String, (Vec<u8>, u32)> = client.gets(&["ascii_foo", "ascii_baz", "not_exists_key"]).await.unwrap();
let values: HashMap<String, (Vec<u8>, u32)> = client
.gets(&["ascii_foo", "ascii_baz", "not_exists_key"])
.await
.unwrap();
assert_eq!(values.len(), 2);
let ascii_foo_value = values.get("ascii_foo").unwrap();
let ascii_baz_value = values.get("ascii_baz").unwrap();
Expand Down
84 changes: 45 additions & 39 deletions tests/tests.rs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -410,42 +410,40 @@ mod nonblocking {
// test with multiple udp connections
let mut handles: Vec<tokio::task::JoinHandle<_>> = Vec::new();
for i in 0..10 {
handles.push(tokio::spawn(
async move {
let key = format!("key{}", i);
let value = format!("value{}", i);
let client = memcache::Client::connect("memcache://localhost:22345?udp=true").unwrap();
for j in 0..50 {
let value = format!("{}{}", value, j);
client.set(key.as_str(), &value, 0).await.unwrap();
let result: Option<String> = client.get(key.as_str()).await.unwrap();
assert_eq!(result.as_ref(), Some(&value));

let result = client.add(key.as_str(), &value, 0).await;
assert_eq!(result.is_err(), true);

client.delete(key.as_str()).await.unwrap();
let result: Option<String> = client.get(key.as_str()).await.unwrap();
assert_eq!(result, None);

client.add(key.as_str(), &value, 0).await.unwrap();
let result: Option<String> = client.get(key.as_str()).await.unwrap();
assert_eq!(result.as_ref(), Some(&value));

client.replace(key.as_str(), &value, 0).await.unwrap();
let result: Option<String> = client.get(key.as_str()).await.unwrap();
assert_eq!(result.as_ref(), Some(&value));

client.append(key.as_str(), &value).await.unwrap();
let result: Option<String> = client.get(key.as_str()).await.unwrap();
assert_eq!(result, Some(format!("{}{}", value, value)));

client.prepend(key.as_str(), &value).await.unwrap();
let result: Option<String> = client.get(key.as_str()).await.unwrap();
assert_eq!(result, Some(format!("{}{}{}", value, value, value)));
}
handles.push(tokio::spawn(async move {
let key = format!("key{}", i);
let value = format!("value{}", i);
let client = memcache::Client::connect("memcache://localhost:22345?udp=true").unwrap();
for j in 0..50 {
let value = format!("{}{}", value, j);
client.set(key.as_str(), &value, 0).await.unwrap();
let result: Option<String> = client.get(key.as_str()).await.unwrap();
assert_eq!(result.as_ref(), Some(&value));

let result = client.add(key.as_str(), &value, 0).await;
assert_eq!(result.is_err(), true);

client.delete(key.as_str()).await.unwrap();
let result: Option<String> = client.get(key.as_str()).await.unwrap();
assert_eq!(result, None);

client.add(key.as_str(), &value, 0).await.unwrap();
let result: Option<String> = client.get(key.as_str()).await.unwrap();
assert_eq!(result.as_ref(), Some(&value));

client.replace(key.as_str(), &value, 0).await.unwrap();
let result: Option<String> = client.get(key.as_str()).await.unwrap();
assert_eq!(result.as_ref(), Some(&value));

client.append(key.as_str(), &value).await.unwrap();
let result: Option<String> = client.get(key.as_str()).await.unwrap();
assert_eq!(result, Some(format!("{}{}", value, value)));

client.prepend(key.as_str(), &value).await.unwrap();
let result: Option<String> = client.get(key.as_str()).await.unwrap();
assert_eq!(result, Some(format!("{}{}{}", value, value, value)));
}
));
}));
}

for handle in handles.into_iter() {
Expand All @@ -470,8 +468,10 @@ mod nonblocking {

client.set("ascii_baz", "qux", 0).await.unwrap();

let values: HashMap<String, (Vec<u8>, u32, Option<u64>)> =
client.gets(&["ascii_foo", "ascii_baz", "not_exists_key"]).await.unwrap();
let values: HashMap<String, (Vec<u8>, u32, Option<u64>)> = client
.gets(&["ascii_foo", "ascii_baz", "not_exists_key"])
.await
.unwrap();
assert_eq!(values.len(), 2);
let ascii_foo_value = values.get("ascii_foo").unwrap();
let ascii_baz_value = values.get("ascii_baz").unwrap();
Expand All @@ -480,11 +480,17 @@ mod nonblocking {
assert!(ascii_baz_value.2.is_some());
assert_eq!(
true,
client.cas("ascii_foo", "bar2", 0, ascii_foo_value.2.unwrap()).await.unwrap()
client
.cas("ascii_foo", "bar2", 0, ascii_foo_value.2.unwrap())
.await
.unwrap()
);
assert_eq!(
false,
client.cas("ascii_foo", "bar3", 0, ascii_foo_value.2.unwrap()).await.unwrap()
client
.cas("ascii_foo", "bar3", 0, ascii_foo_value.2.unwrap())
.await
.unwrap()
);

assert_eq!(
Expand Down

0 comments on commit c9a651f

Please sign in to comment.