Struct WsService 

pub struct WsService { /* private fields */ }

Implementations

impl WsService

pub fn new(url: impl IntoUrl, access_token: Option<String>) -> Result<Self>

impl WsService

pub fn get_url(&self) -> Url

pub async fn connect( url: impl ToString, ) -> Result<WebSocketStream<MaybeTlsStream<TcpStream>>, Error>

pub async fn send_processor( send_side: SplitSink<WebSocketStream<MaybeTlsStream<TcpStream>>, Message>, api_receiver: APIReceiver, close_signal: Receiver<()>, ) -> Result<()>

pub async fn read_processor( read_side: SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, event_sender: EventSender, close_signal: Receiver<()>, ) -> Result<()>

Trait Implementations

impl Clone for WsService

fn clone(&self) -> WsService

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl CommunicationService for WsService

fn inject(&mut self, api_receiver: APIReceiver, event_sender: EventSender)

fn start_service<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ServiceStartResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

impl Debug for WsService

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

Formats the value using the given formatter.

impl Drop for WsService

fn drop(&mut self)

Executes the destructor for this type.