Struct vkclient::LongPollClient

pub struct LongPollClient { /* private fields */ }

Client for long poll subscriptions

Use it to subscribe on some VK events, like the UserLong Poll API or the Bots Long Poll API.

Usage:

use vkclient::VkApi;
let client: VkApi = vkclient::VkApiBuilder::new(access_token).into();

let longpoll_client = client.longpoll();

use vkclient::LongPollClient;

let longpoll_client = LongPollClient::default();

Implementations

impl LongPollClient

pub fn subscribe<T: Serialize + Clone, I: DeserializeOwned>(
    &self,
    request: LongPollRequest<T>
) -> impl Stream<Item = Result<I, VkApiError>>

Returns an events stream from long poll server.

Usage

use vkclient::{LongPollClient, LongPollRequest};

let longpoll_client = LongPollClient::default();

longpoll_client.subscribe(LongPollRequest {
        key,
        server,
        ts,
        wait: 25,
        additional_params: (),
    })
    .take(1)
    .for_each(|r| async move { println!("{:?}", r) });

pub async fn subscribe_once<T: Serialize, I: DeserializeOwned>(
    &self,
    request: LongPollRequest<T>
) -> Result<LongPollSuccess<I>, VkApiError>

Returns first events chunk from long poll server.

Usage

use vkclient::{LongPollClient, LongPollRequest};

let longpoll_client = LongPollClient::default();

longpoll_client.subscribe_once(LongPollRequest {
        key,
        server,
        ts,
        wait: 25,
        additional_params: (),
    });

Trait Implementations

impl Clone for LongPollClient

fn clone(&self) -> LongPollClient

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for LongPollClient

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

Formats the value using the given formatter.

impl Default for LongPollClient

fn default() -> Self

Returns the “default value” for a type.

impl From<Client<HttpsConnector<HttpConnector<GaiResolver>>, Body>> for LongPollClient

fn from(client: Client<HttpsConnector<HttpConnector>, Body>) -> Self

Converts to this type from the input type.