Skip to content

Commit d834cbc

Browse files
authored
Make GooglePubSubPublisher cloneable (#33)
* Make GooglePubSubPublisher cloneable Sometimes it's useful to have more than one * Add some debug derives * Release v4.1.0
1 parent b8fed45 commit d834cbc

File tree

3 files changed

+4
-1
lines changed

3 files changed

+4
-1
lines changed

Cargo.toml

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
[package]
22
name = "hedwig"
33
# TODO: When bumping to next major version, make sure to clean up the MRV and lints we allow in CI.
4-
version = "4.0.0"
4+
version = "4.1.0"
55
authors = [
66
"Aniruddha Maru <[email protected]>",
77
"Simonas Kazlauskas <[email protected]>"

src/consume/mod.rs

+2
Original file line numberDiff line numberDiff line change
@@ -96,6 +96,7 @@ pub trait DecodableMessage {
9696
/// service.
9797
///
9898
/// See the documentation for acknowledging messages on [`Consumer`]
99+
#[derive(Debug)]
99100
#[must_use = "Messages should be ack'ed to prevent repeated delivery, or nack'ed to improve responsiveness"]
100101
pub struct AcknowledgeableMessage<A, M> {
101102
/// The acknowledgement token which executes the ack/nack/modify operations
@@ -175,6 +176,7 @@ pub trait AcknowledgeToken {
175176

176177
/// The stream returned by the [`consume`](Consumer::consume) function
177178
#[pin_project]
179+
#[derive(Debug)]
178180
pub struct MessageStream<S, D, M> {
179181
#[pin]
180182
stream: S,

src/publish/publishers/googlepubsub.rs

+1
Original file line numberDiff line numberDiff line change
@@ -189,6 +189,7 @@ impl GooglePubSubError {
189189
/// };
190190
/// ```
191191
#[allow(missing_debug_implementations)]
192+
#[derive(Clone)]
192193
#[cfg_attr(docsrs, doc(cfg(feature = "google")))]
193194
pub struct GooglePubSubPublisher<C> {
194195
identifier: Cow<'static, str>,

0 commit comments

Comments
 (0)