Struct signalr_rs::hub::client::HubClient

pub struct HubClient {
    pub cookies: String,
    // some fields omitted
}

Fields

cookies: String

Methods

impl HubClient

pub async fn new<'_>(
    hub: &'static str,
    wss_url: &'_ str,
    query_backoff: u64,
    restart_policy: RestartPolicy,
    handler: Box<dyn HubClientHandler>
) -> Result<Addr<HubClient>, HubClientError>

Trait Implementations

impl Actor for HubClient

type Context = Context<Self>

Actor execution context type

fn started(&mut self, ctx: &mut Context<Self>)

Called when an actor gets polled the first time.

fn stopped(&mut self, _: &mut Context<Self>)

Called after an actor is stopped.

fn stopping(&mut self, ctx: &mut Self::Context) -> Running

Called after an actor is in Actor::Stopping state.

fn start(self) -> Addr<Self> where
    Self: Actor<Context = Context<Self>>, 

Start a new asynchronous actor, returning its address.

fn start_default() -> Addr<Self> where
    Self: Actor<Context = Context<Self>> + Default, 

Construct and start a new asynchronous actor, returning its address.

fn start_in_arbiter<F>(arb: &Arbiter, f: F) -> Addr<Self> where
    F: FnOnce(&mut Context<Self>) -> Self + Send + 'static,
    Self: Actor<Context = Context<Self>>, 

Start new actor in arbiter's thread.

fn create<F>(f: F) -> Addr<Self> where
    F: FnOnce(&mut Context<Self>) -> Self,
    Self: Actor<Context = Context<Self>>, 

Start a new asynchronous actor given a Context.

impl<'de, T> Handler<HubQuery<T>> for HubClient where
    T: Deserialize<'de> + Serialize + 'static, 

type Result = ()

The type of value that this handler will return.

fn handle(&mut self, msg: HubQuery<T>, ctx: &mut Self::Context) -> Self::Result

This method is called for every message received by this actor.

impl StreamHandler<Result<Frame, ProtocolError>> for HubClient

fn handle(
    &mut self,
    msg: Result<Frame, WsProtocolError>,
    ctx: &mut Context<Self>
)

Method is called for every message received by this Actor

fn started(&mut self, ctx: &mut Self::Context)

Method is called when stream get polled first time.

fn finished(&mut self, ctx: &mut Self::Context)

Method is called when stream finishes.

fn add_stream<S>(fut: S, ctx: &mut Self::Context) -> SpawnHandle where
    I: 'static,
    S: Stream<Item = I> + 'static,
    Self::Context: AsyncContext<Self>, 

This method register stream to an actor context and allows to handle Stream in similar way as normal actor messages.

impl Supervised for HubClient

Upon disconnection of the ws client, recreate the ws client

fn restarting(&mut self, ctx: &mut Self::Context)

Called when the supervisor restarts a failed actor.

impl WriteHandler<ProtocolError> for HubClient

fn error(&mut self, err: E, ctx: &mut Self::Context) -> Running

Called when the writer emits error.

fn finished(&mut self, ctx: &mut Self::Context)

Called when the writer finishes.