fn broadcast(&mut self, sse_data: SseData) -> Effects<Event> {
        let event_index = self.event_indexer.next_index();
        let _ = self.sse_data_sender.send((event_index, sse_data));
        Effects::new()
    }
/// Broadcasts the SSE data to all clients connected to the event stream.
Broadcasts the SSE data to all clients connected to the event stream.
Broadcasts the SSE data to all clients connected to the event stream .
fn broadcast(&mut self, sse_data: SseData) -> Effects<Event> {
        let event_index = self.event_indexer.next_index();
        let _ = self.sse_data_sender.send((event_index, sse_data));
        Effects::new()
    }
fn broadcast ( & mut self , sse_data : SseData ) -> Effects < Event > { let event_index = self . event_indexer . next_index ( ) ; let _ = self . sse_data_sender . send ( ( event_index , sse_data ) ) ; Effects :: new ( ) }
Broadcasts the SSE data to all clients connected to the event stream.
Broadcasts the SSE data to all clients connected to the event stream .
&mut self
sse_data
SseData
&mut self
sse_data
SseData