nash-native-client 0.3.0

native rust client for interacting with nash exchange via websockets
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

use std::{pin::Pin, task::Context, task::Poll};

use futures::stream::Stream;

use nash_protocol::errors::Result;
use nash_protocol::protocol::subscriptions::SubscriptionResponse;
use nash_protocol::protocol::ResponseOrError;

use crate::Client;

impl Stream for Client {
    type Item = Result<ResponseOrError<SubscriptionResponse>>;

    fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> {
        self.global_subscription_receiver.poll_recv(cx)
    }
}