Struct barter_data::builder::StreamBuilder
source · [−]pub struct StreamBuilder { /* private fields */ }Expand description
Builder to configure and initialise Streams instances.
Implementations
sourceimpl StreamBuilder
impl StreamBuilder
sourcepub fn subscribe<SubIter, Sub>(
self,
exchange: ExchangeTransformerId,
subscriptions: SubIter
) -> Self where
SubIter: IntoIterator<Item = Sub>,
Sub: Into<Subscription>,
pub fn subscribe<SubIter, Sub>(
self,
exchange: ExchangeTransformerId,
subscriptions: SubIter
) -> Self where
SubIter: IntoIterator<Item = Sub>,
Sub: Into<Subscription>,
Add a set of Subscriptions for an exchange to the StreamBuilder. Note
that provided Subscriptions are not actioned until the init()
method is invoked.
sourcepub async fn init(self) -> Result<Streams, SocketError>
pub async fn init(self) -> Result<Streams, SocketError>
Spawn a MarketData consumer loop for each exchange that distributes events to the
returned Streams HashMap.
Trait Implementations
sourceimpl Debug for StreamBuilder
impl Debug for StreamBuilder
sourceimpl Validator for StreamBuilder
impl Validator for StreamBuilder
sourcefn validate(self) -> Result<Self, SocketError> where
Self: Sized,
fn validate(self) -> Result<Self, SocketError> where
Self: Sized,
Check if Self is valid for some use case.
Auto Trait Implementations
impl RefUnwindSafe for StreamBuilder
impl Send for StreamBuilder
impl Sync for StreamBuilder
impl Unpin for StreamBuilder
impl UnwindSafe for StreamBuilder
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
fn vzip(self) -> V
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
Attaches the provided Subscriber to this type, returning a
WithDispatch wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber to this type, returning a
WithDispatch wrapper. Read more