Websocket JSON несоответствие типов парсинга - PullRequest
Новая
       30

Websocket JSON несоответствие типов парсинга

0 голосов
/ 26 мая 2020

Я пытаюсь собрать простой клиент WebSocket с использованием вольфрама, который анализирует JSON. Большая часть кода взята из этого примера .

Если я делаю println!("{}", msg) Он работает нормально, поэтому я не уверен, почему тип не совпадает (msg предположительно является строкой право?). https://docs.rs/tungstenite/0.6.1/tungstenite/protocol/enum.Message.html

use tungstenite::{connect};
use url::Url;
use serde_json;

fn main() {

    let (mut socket, _response) =
        connect(Url::parse("wss://www.bitmex.com/realtime?subscribe=trade:XBTUSD").unwrap()).expect("Can't connect");

    loop {
        let msg = socket.read_message().expect("Error reading message");
        let parsed: serde_json::Value = serde_json::from_str(&msg).expect("Can't parse to JSON");
        println!("{:?}", parsed["data"][0]["price"]);
    }

}

error[E0308]: mismatched types
  --> src/main.rs:12:62
   |
12 |         let parsed: serde_json::Value = serde_json::from_str(&msg).expect("Can't parse to JSON");
   |                                                              ^^^^ expected `str`, found enum `tungstenite::protocol::message::Message`
   |
   = note: expected reference `&str`
              found reference `&tungstenite::protocol::message::Message`

[dependencies]
tungstenite = "0.10.1"
url = "2.1.1"
serde_json = "1.0.53"

1 Ответ

0 голосов
/ 26 мая 2020

Будет работать примерно так: 

use tungstenite::{connect};
use url::Url;
use serde_json;

fn main() {

    let (mut socket, _response) =
        connect(Url::parse("wss://www.bitmex.com/realtime?subscribe=trade:XBTUSD").unwrap()).expect("Can't connect");

    loop {
        let msg = socket.read_message().expect("Error reading message");
        let msg = match msg {
            tungstenite::Message::Text(s) => { s }
            _ => { panic!() }
        };
        let parsed: serde_json::Value = serde_json::from_str(&msg).expect("Can't parse to JSON");
        println!("{:?}", parsed["data"][0]["price"]);
    }

}
...