|
|
@ -5,13 +5,12 @@ use tokio::sync::{oneshot, Mutex};
|
|
|
|
use tokio_tungstenite::tungstenite::Message;
|
|
|
|
use tokio_tungstenite::tungstenite::Message;
|
|
|
|
use tracing::debug;
|
|
|
|
use tracing::debug;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
use super::InnerError;
|
|
|
|
use crate::{
|
|
|
|
use crate::{
|
|
|
|
requests::{ClientRequest, EventSubscription, Identify},
|
|
|
|
requests::{ClientRequest, EventSubscription, Identify},
|
|
|
|
responses::{Hello, Identified, RequestResponse, ServerMessage, Status},
|
|
|
|
responses::{Hello, Identified, RequestResponse, ServerMessage, Status},
|
|
|
|
};
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
|
|
use super::InnerError;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/// Wrapper for the list of ongoing requests that wait for response.
|
|
|
|
/// Wrapper for the list of ongoing requests that wait for response.
|
|
|
|
#[derive(Default)]
|
|
|
|
#[derive(Default)]
|
|
|
|
pub(super) struct ReceiverList(Mutex<HashMap<u64, oneshot::Sender<(Status, serde_json::Value)>>>);
|
|
|
|
pub(super) struct ReceiverList(Mutex<HashMap<u64, oneshot::Sender<(Status, serde_json::Value)>>>);
|
|
|
|