Struct cloud_pubsub::client::Client

pub struct Client(_);

Implementations

impl Client

pub async fn from_string(credentials_string: String) -> Result<Self, Error>

pub async fn new(credentials_path: String) -> Result<Self, Error>

pub fn subscribe(&self, name: String) -> Subscription

pub fn set_project(&mut self, project: String)

pub fn project(&self) -> String

pub fn topic(&self, name: String) -> Topic

pub fn is_running(&self) -> bool

pub fn stop(&self)

pub fn spawn_token_renew(&self, interval: Duration)

pub async fn refresh_token(&mut self) -> Result<(), Error>

pub fn hyper_client(&self) -> Arc<Client<HttpsConnector<HttpConnector>, Body>>

Trait Implementations

impl Clone for Client

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.