Struct ClientStompHandle 

pub struct ClientStompHandle<T>
where
    T: ClientTransport,
    T::ProtocolSideChannel: Debug,
{ /* private fields */ }

A handle that reads and writes STOMP messages given an implementation of ClientTransport.

Implementations

impl<T> ClientStompHandle<T>

where T: ClientTransport, T::ProtocolSideChannel: Debug,

pub async fn connect( transport: T, virtualhost: String, login: Option<String>, passcode: Option<String>, headers: Vec<(String, String)>, ) -> Result<ClientStompHandle<T>>

Creates a new ClientStompHandle for your code to interface with. Requires an implementation of ClientTransport.

pub async fn send_message( &mut self, message: Message<ToServer>, ) -> Result<(), WriteError>

Send a STOMP message through the underlying transport

pub async fn read_response( &mut self, ) -> Result<ServerResponse<T::ProtocolSideChannel>, ReadError>

Read a STOMP message from the underlying transport

pub fn into_transport(self) -> T

Consume the ClientStompHandle to get the original ClientTransport back.

pub fn as_mut_transport(&mut self) -> &mut T

Get a mutable reference to the transport, to be able to handle e.g. WebSocket Ping/Pong