Skip to content

Commit

Permalink
Improve test assertions
Browse files Browse the repository at this point in the history
Signed-off-by: Tomasz Pietrek <[email protected]>
  • Loading branch information
Jarema committed Feb 2, 2024
1 parent 50cf980 commit 9e6c5ab
Showing 1 changed file with 6 additions and 1 deletion.
7 changes: 6 additions & 1 deletion async-nats/tests/jetstream_tests.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1157,6 +1157,10 @@ mod jetstream {
.delete_consumer_from_stream("pull", "stream")
.await
.unwrap();
assert!(stream
.get_consumer::<consumer::Config>("pull")
.await
.is_err());
}

#[tokio::test]
Expand All @@ -1173,7 +1177,7 @@ mod jetstream {
})
.await
.unwrap();
context
let consumer = context
.create_consumer_on_stream(
consumer::push::Config {
durable_name: Some("push".into()),
Expand All @@ -1184,6 +1188,7 @@ mod jetstream {
)
.await
.unwrap();
assert_eq!(consumer.cached_info().name, "push");
}

#[tokio::test]
Expand Down

0 comments on commit 9e6c5ab

Please sign in to comment.