Struct WebSocketClient

pub struct WebSocketClient { /* private fields */ }

Asynchronous WebSocket-based client for Misskey.

WebSocketClient can be constructed using WebSocketClient::connect or WebSocketClientBuilder. The latter is more flexible and intuitive.

You do not have to wrap this in Arc and Mutex to share it because WebSocketClient is already Clone and every methods of WebSocketClient takes &self, i.e. they does not require mutability.

Implementations

impl WebSocketClient

pub async fn connect(url: Url) -> Result<WebSocketClient, Error>

Connects to Misskey using WebSocket, and returns WebSocketClient.

pub async fn connect_with_config( url: Url, reconnect_config: ReconnectConfig, ) -> Result<WebSocketClient, Error>

Connects to Misskey using WebSocket with a given reconnect configuration, and returns WebSocketClient.

pub fn builder<T>(url: T) -> WebSocketClientBuilder

where T: TryInto<Url>, T::Error: Into<Error>,

Creates a new builder instance with url. All configurations are set to default.

This function is identical to WebSocketClientBuilder::new.

pub fn subnote<E, Id>( &self, note_id: Id, ) -> BoxFuture<'static, Result<SubNote<E>, Error>>

where E: SubNoteEvent, Id: Into<String>,

Captures the note specified by id.

The returned SubNote implements Stream so that note events can be retrieved asynchronously via it.

pub fn channel<R>( &self, request: R, ) -> BoxFuture<'static, Result<Channel<R::Incoming, R::Outgoing>, Error>>

where R: ConnectChannelRequest,

Connects to the channel using request.

The returned Channel implements Stream and Sink so that you can exchange messages with channels on it.

pub fn broadcast<E>(&self) -> BoxFuture<'static, Result<Broadcast<E>, Error>>

where E: BroadcastEvent,

Receive messages from the broadcast stream.

The returned Broadcast implements Stream so that broadcast events can be retrieved asynchronously via it.

Trait Implementations

impl Client for WebSocketClient

type Error = Error

The error type produced by the client when an error occurs.

fn request<R: Request>( &self, request: R, ) -> BoxFuture<'_, Result<ApiResult<R::Response>, Error>>

Dispatch an API request.

impl Clone for WebSocketClient

fn clone(&self) -> WebSocketClient

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for WebSocketClient

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

Formats the value using the given formatter.

impl StreamingClient for WebSocketClient

type Error = Error

The error type produced by the client when an error occurs.

fn subnote<E>( &self, note_id: String, ) -> BoxFuture<'_, Result<BoxStream<'_, Result<E, Error>>, Error>>

where E: SubNoteEvent,

Captures the note specified by note_id.

fn channel<R>( &self, request: R, ) -> BoxFuture<'_, Result<ChannelStream<'_, R, Error>, Error>>

where R: ConnectChannelRequest,

Connects to the channel using request.

fn broadcast<E>( &self, ) -> BoxFuture<'_, Result<BoxStream<'_, Result<E, Error>>, Error>>

where E: BroadcastEvent,

Receive messages from the broadcast stream.