diff --git a/async-nats/src/jetstream/context.rs b/async-nats/src/jetstream/context.rs index b21b8e3b2..64e5115e8 100644 --- a/async-nats/src/jetstream/context.rs +++ b/async-nats/src/jetstream/context.rs @@ -195,6 +195,14 @@ impl Context { publish: Publish, ) -> Result { let subject = subject.to_subject(); + + if subject.is_empty() { + return Err(PublishError::with_source( + PublishErrorKind::Other, + "empty subject is not allowed", + )); + } + let (sender, receiver) = oneshot::channel(); let respond = self.client.new_inbox().into();