Struct WebSocketSink 

pub struct WebSocketSink { /* private fields */ }

WebSocket notification sink

Receives payloads from the deliver operator and dispatches them to connected WebSocket clients via the WebSocketDispatcher.

Implementations

impl WebSocketSink

pub fn new(dispatcher: Arc<dyn WebSocketDispatcher>) -> Self

Create a new WebSocketSink with a dispatcher

Trait Implementations

impl Debug for WebSocketSink

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

Formats the value using the given formatter.

impl Sink for WebSocketSink

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)