We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 70f117b commit f39e81eCopy full SHA for f39e81e
1 file changed
rsworkspace/crates/trogon-nats/src/client.rs
@@ -97,10 +97,12 @@ impl PublishClient for async_nats::jetstream::Context {
97
async fn publish_with_headers<S: ToSubject + Send>(
98
&self,
99
subject: S,
100
- _headers: HeaderMap,
+ headers: HeaderMap,
101
payload: Bytes,
102
) -> Result<(), Self::PublishError> {
103
- self.publish(subject, payload).await?.await?;
+ self.publish_with_headers(subject, headers, payload)
104
+ .await?
105
+ .await?;
106
Ok(())
107
}
108
0 commit comments