Skip to content

Commit 94ee677

Browse files
'declare stream': make --expiration mandatory
1 parent a07e5d5 commit 94ee677

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

src/cli.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -566,7 +566,7 @@ fn declare_subcommands() -> [Command; 12] {
566566
Arg::new("expiration")
567567
.long("expiration")
568568
.help("stream expiration, e.g. 12h for 12 hours, 7D for 7 days, or 1M for 1 month")
569-
.required(false)
569+
.required(true)
570570
.value_parser(clap::value_parser!(String)),
571571
)
572572
.arg(

tests/streams_tests.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,7 @@ fn list_streams() -> Result<(), Box<dyn std::error::Error>> {
6161

6262
// list streams in vhost 1
6363
run_succeeds(["-V", vh1, "list", "queues"])
64-
.stdout(predicate::str::contains(s1).and(predicate::str::contains("new_stream2").not()));
64+
.stdout(predicate::str::contains(s1).and(predicate::str::contains("random_stream").not()));
6565

6666
// delete the stream in vhost 1
6767
run_succeeds(["-V", vh1, "delete", "stream", "--name", s1]);

0 commit comments

Comments
 (0)