Struct openlimits_exchange::traits::stream::OpenLimitsWs [−][src]
pub struct OpenLimitsWs<E: ExchangeWs> {
pub websocket: E,
}Fields
websocket: EImplementations
pub async fn create_stream_specific(
&self,
subscriptions: Subscriptions<E::Subscription>
) -> Result<BoxStream<'static, Result<E::Response>>>
pub async fn subscribe<F: Fn(&Result<WebSocketResponse<E::Response>>) + Sync + Send + 'static>(
&self,
subscription: Subscription,
callback: F
) -> Result<CallbackHandle>
pub async fn create_stream<S: Into<E::Subscription> + Clone + Send + Sync>(
&self,
subscriptions: &[S]
) -> Result<BoxStream<'static, Result<WebSocketResponse<E::Response>>>>
Auto Trait Implementations
impl<E> RefUnwindSafe for OpenLimitsWs<E> where
E: RefUnwindSafe,
impl<E> Send for OpenLimitsWs<E>
impl<E> Sync for OpenLimitsWs<E>
impl<E> Unpin for OpenLimitsWs<E> where
E: Unpin,
impl<E> UnwindSafe for OpenLimitsWs<E> where
E: UnwindSafe,
Blanket Implementations
Mutably borrows from an owned value. Read more
pub fn vzip(self) -> V
Attaches the provided Subscriber to this type, returning a
WithDispatch wrapper. Read more
Attaches the current default Subscriber to this type, returning a
WithDispatch wrapper. Read more