Function tensor_trade_stream::subscribe

source · 
pub async fn subscribe<T: GraphQLQuery + Send + Sync + Unpin + 'static>(
    client: AsyncWebsocketClient<GraphQLClient, Message>,
    variables: T::Variables
) -> Result<SubscriptionStream<GraphQLClient, StreamingOperation<T>>>
where
    <T as GraphQLQuery>::Variables: Send + Sync + Unpin,
    <T as GraphQLQuery>::ResponseData: Debug,
Examples found in repository?
examples/tensorswap_order_update_all.rs (line 19)
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30

async fn main() -> Result<()> {
    let client = match connect().await {
        Ok(client) => client,
        Err(e) => {
            eprintln!("Error connecting to websocket: {}", e);
            return Ok(());
        }
    };

    let mut stream =
        subscribe::<TensorswapOrderUpdateAllQuery>(client, TensorswapOrderUpdateAllVariables {})
            .await?;

    while let None = stream.next().await {
        // let data = event?.data;
        // let response: TensorswapOrderUpdateAllResponse =
        //     data.unwrap().tswap_order_update_all.unwrap();
        dbg!(&stream.next().await);
    }

    Ok(())
}