13280939567

Committed 12 Feb 2025 08:18AM UTC coverage: 75.132% (-0.06%) from 75.192%

Build # 13280939567

Build Type

Pull #1514

github

Committed by

web-flow

Commit Message

Merge d9a2e8c28 into 19db87131

Pull Request Pull Request #1514: Epilogue part 1

Run Details

0 of 24 new or added lines in 2 files covered. (0.0%)

2 existing lines in 2 files now uncovered.

25022 of 33304 relevant lines covered (75.13%)

9818.21 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/sdk/src/consumer_ext/mod.rs

mod consumer_message_ext;
mod consumer_message_trait;

pub use consumer_message_trait::IggyConsumerMessageExt;

use crate::error::IggyError;
use crate::models::messages::PolledMessage;

/// Trait for event consumer
#[allow(dead_code)] // Clippy can't see that the trait is used
#[trait_variant::make(MessageConsumer: Send)]
pub trait LocalMessageConsumer {
    /// Consume a message from the message bus.
    ///
    /// # Arguments
    ///
    /// * `data` - The event data
    ///
    /// # Errors
    ///
    /// * `IggyError` - If the message consumer fails to consume the message
    async fn consume(&self, message: PolledMessage) -> Result<(), IggyError>;
}

// Default implementation for `&T`
// https://users.rust-lang.org/t/hashmap-get-dereferenced/33558
impl<T: MessageConsumer + Send + Sync> MessageConsumer for &T {
    /// Consume a message from the message bus.
    ///
    /// # Arguments
    ///
    /// * `data` - The event data
    ///
    /// # Errors
    ///
    /// * `IggyError` - If the message consumer fails to consume the message
    async fn consume(&self, message: PolledMessage) -> Result<(), IggyError> {
        (**self).consume(message).await
    }
}

1	mod consumer_message_ext;
2	mod consumer_message_trait;
3
4	pub use consumer_message_trait::IggyConsumerMessageExt;
5
6	use crate::error::IggyError;
7	use crate::models::messages::PolledMessage;
8
9	/// Trait for event consumer
10	#[allow(dead_code)] // Clippy can't see that the trait is used
11	#[trait_variant::make(MessageConsumer: Send)]
12	pub trait LocalMessageConsumer {
13	/// Consume a message from the message bus.
14	///
15	/// # Arguments
16	///
17	/// * `data` - The event data
18	///
19	/// # Errors
20	///
21	/// * `IggyError` - If the message consumer fails to consume the message
22	async fn consume(&self, message: PolledMessage) -> Result<(), IggyError>;
23	}
24
25	// Default implementation for `&T`
26	// https://users.rust-lang.org/t/hashmap-get-dereferenced/33558
27	impl<T: MessageConsumer + Send + Sync> MessageConsumer for &T {
28	/// Consume a message from the message bus.
29	///
30	/// # Arguments
31	///
32	/// * `data` - The event data
33	///
34	/// # Errors
35	///
36	/// * `IggyError` - If the message consumer fails to consume the message
NEW 37	async fn consume(&self, message: PolledMessage) -> Result<(), IggyError> {	×
NEW 38	(**self).consume(message).await	×
NEW 39	}	×
40	}

iggy-rs / iggy / 13280939567

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous