Struct pubnub_hyper::core::PubNub

pub struct PubNub<TTransport, TRuntime> where
    TTransport: Transport,
    TRuntime: Runtime,  { /* private fields */ }

PubNub Client

The PubNub lib implements socket pools to relay data requests as a client connection to the PubNub Network.

Implementations

impl<TTransport, TRuntime> PubNub<TTransport, TRuntime> where
    TTransport: 'static + Transport,
    TRuntime: 'static + Runtime, 

pub async fn subscribe_to_presence(
    &mut self,
    channel: Name
) -> Subscription<TRuntime>

Subscribe to presence events for the specified channel.

This is just a tiny wrapper that calls PubNub::subscribe internally with the specified channel name with a -pnpres suffix.

impl<TTransport, TRuntime> PubNub<TTransport, TRuntime> where
    TTransport: 'static + Transport,
    TRuntime: 'static + Runtime, 

pub async fn publish(
    &self,
    channel: Name,
    message: JsonValue
) -> Result<Timetoken, <TTransport as Transport>::Error>

Publish a message over the PubNub network.

Errors

Returns transport-specific errors.

Example

use pubnub_core::{data::channel, json::object, Builder};

let pubnub = Builder::with_components(transport, runtime).build();

let channel_name: channel::Name = "my-channel".parse().unwrap();
let timetoken = pubnub
    .publish(
        channel_name,
        object! {
            "username" => "JoeBob",
            "content" => "Hello, world!",
        },
    )
    .await?;

println!("Timetoken: {}", timetoken);

pub async fn publish_with_metadata(
    &self,
    channel: Name,
    message: JsonValue,
    metadata: JsonValue
) -> Result<Timetoken, <TTransport as Transport>::Error>

Publish a message over the PubNub network with an extra metadata payload.

Errors

Returns transport-specific errors.

Example

use pubnub_core::{data::channel, json::object, Builder};

let pubnub = Builder::with_components(transport, runtime).build();

let message = object! {
    "username" => "JoeBob",
    "content" => "Hello, world!",
};
let metadata = object! {
    "uuid" => "JoeBob",
};

let channel_name: channel::Name = "my-channel".parse().unwrap();
let timetoken = pubnub
    .publish_with_metadata(channel_name, message, metadata)
    .await?;

println!("Timetoken: {}", timetoken);

impl<TTransport, TRuntime> PubNub<TTransport, TRuntime> where
    TTransport: 'static + Transport,
    TRuntime: 'static + Runtime, 

pub async fn subscribe(&mut self, channel: Name) -> Subscription<TRuntime>

Subscribe to a message stream over the PubNub network.

The PubNub client only maintains a single subscribe loop for all subscription streams. This has a benefit that it optimizes for a low number of sockets to the PubNub network. It has a downside that requires all streams to consume faster than the subscribe loop produces. A slow consumer will create a head-of-line blocking bottleneck in the processing of received messages. All streams can only consume as fast as the slowest.

For example, with 3 total subscription streams and 1 that takes 30 seconds to process each message; the other 2 streams will be blocked waiting for that 30-second duration on the slow consumer.

Example

use futures_util::stream::StreamExt;
use pubnub_core::{data::channel, json::object, Builder};

let mut pubnub = Builder::with_components(transport, runtime).build();
let channel_name: channel::Name = "my-channel".parse().unwrap();
let mut stream = pubnub.subscribe(channel_name).await;

while let Some(message) = stream.next().await {
    println!("Received message: {:?}", message);
}

impl<TTransport, TRuntime> PubNub<TTransport, TRuntime> where
    TTransport: 'static + Transport,
    TRuntime: 'static + Runtime, 

pub fn transport(&self) -> &TTransport

Get a reference to a transport being used.

pub fn runtime(&self) -> &TRuntime

Get a reference to a runtime being used.

impl<TTransport, TRuntime> PubNub<TTransport, TRuntime> where
    TTransport: 'static + Transport,
    TRuntime: 'static + Runtime, 

pub async fn call<TRequest>(
    &self,
    req: TRequest
) -> Result<<TTransport as Service<TRequest>>::Response, <TTransport as Service<TRequest>>::Error> where
    TTransport: Service<TRequest>, 

Perform a transport call.

Errors

Returns transport-specific errors.

Trait Implementations

impl<TTransport, TRuntime> Clone for PubNub<TTransport, TRuntime> where
    TTransport: Clone + Transport,
    TRuntime: Clone + Runtime, 

fn clone(&self) -> PubNub<TTransport, TRuntime>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<TTransport, TRuntime> Debug for PubNub<TTransport, TRuntime> where
    TTransport: Debug + Transport,
    TRuntime: Debug + Runtime, 

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

Formats the value using the given formatter.