Struct PushNotificationSink 

pub struct PushNotificationSink { /* private fields */ }

Push notification sink

Receives payloads from the deliver operator and sends push notifications to all registered device tokens for the recipient.

Preferences

If a NotificationPreferencesStore is attached via with_preferences, the sink checks user preferences before sending. Disabled notification types are silently dropped (same pattern as InAppNotificationSink).

Stale token cleanup

When a push provider returns PermanentError (e.g., DeviceNotRegistered), the corresponding device token is automatically unregistered from the store.

Implementations

impl PushNotificationSink

pub fn with_provider( device_tokens: Arc<DeviceTokenStore>, provider: Arc<dyn PushProvider>, ) -> Self

Create with a custom push provider

pub fn with_config( device_tokens: Arc<DeviceTokenStore>, provider: Arc<dyn PushProvider>, retry_config: RetryConfig, ) -> Self

Create with custom provider and retry config

pub fn with_preferences( self, preferences: Arc<NotificationPreferencesStore>, ) -> Self

Attach a preferences store to check before sending

When set, the sink checks is_enabled(recipient, notification_type) before sending. Disabled types are silently dropped.

Trait Implementations

impl Debug for PushNotificationSink

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Sink for PushNotificationSink

fn deliver<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, payload: Value, recipient_id: Option<&'life1 str>, context_vars: &'life2 HashMap<String, Value>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Deliver a payload to this sink

fn name(&self) -> &str

Human-readable name for this sink instance

fn sink_type(&self) -> SinkType

The sink type (matches SinkConfig.sink_type)