pub struct Worker { /* private fields */ }Expand description
Asset worker for subscribing to asset updates via the Binance WebSocket API.
The Worker manages asynchronous WebSocket connections for asset updates
and ensures resources are properly cleaned up when dropped.
Trait Implementations§
Source§impl AssetWorker for Worker
impl AssetWorker for Worker
Source§fn build<'life0, 'async_trait, S>(
opts: Self::Opts,
store: &'life0 S,
ids: Vec<String>,
) -> Pin<Box<dyn Future<Output = Result<Self, AssetWorkerError>> + Send + 'async_trait>>where
S: 'async_trait + Store + 'static,
Self: 'async_trait,
'life0: 'async_trait,
fn build<'life0, 'async_trait, S>(
opts: Self::Opts,
store: &'life0 S,
ids: Vec<String>,
) -> Pin<Box<dyn Future<Output = Result<Self, AssetWorkerError>> + Send + 'async_trait>>where
S: 'async_trait + Store + 'static,
Self: 'async_trait,
'life0: 'async_trait,
Builds and starts the BinanceWorker.
This method creates a Binance WebSocket client, spawns asynchronous tasks
to subscribe to asset updates, and returns the running Worker instance.
Source§type Opts = WorkerOpts
type Opts = WorkerOpts
Configuration options for the worker. Read more
Auto Trait Implementations§
impl Freeze for Worker
impl RefUnwindSafe for Worker
impl Send for Worker
impl Sync for Worker
impl Unpin for Worker
impl UnsafeUnpin for Worker
impl UnwindSafe for Worker
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request