pub struct FeedHandler { /* private fields */ }Expand description
Processes raw WebSocket messages into Nautilus domain types.
Implementations§
Source§impl FeedHandler
impl FeedHandler
Sourcepub fn new(
signal: Arc<AtomicBool>,
cmd_rx: UnboundedReceiver<HandlerCommand>,
raw_rx: UnboundedReceiver<Message>,
subscription_aliases: Arc<AtomicMap<Ustr, Ustr>>,
) -> Self
pub fn new( signal: Arc<AtomicBool>, cmd_rx: UnboundedReceiver<HandlerCommand>, raw_rx: UnboundedReceiver<Message>, subscription_aliases: Arc<AtomicMap<Ustr, Ustr>>, ) -> Self
Creates a new FeedHandler instance.
Sourcepub fn set_account_id(&mut self, account_id: AccountId)
pub fn set_account_id(&mut self, account_id: AccountId)
Sets the account ID used to stamp user-channel execution reports.
Sourcepub async fn next(&mut self) -> Option<NautilusWsMessage>
pub async fn next(&mut self) -> Option<NautilusWsMessage>
Polls for the next output message, processing commands and raw messages.
Returns None when the handler should shut down.
Trait Implementations§
Auto Trait Implementations§
impl Freeze for FeedHandler
impl !RefUnwindSafe for FeedHandler
impl Send for FeedHandler
impl Sync for FeedHandler
impl Unpin for FeedHandler
impl UnsafeUnpin for FeedHandler
impl !UnwindSafe for FeedHandler
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
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§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 more