|
|
@ -1,4 +1,5 @@
|
|
|
|
use futures_util::{stream::SplitSink, SinkExt, StreamExt};
|
|
|
|
use futures_util::{stream::SplitSink, SinkExt, StreamExt};
|
|
|
|
|
|
|
|
use http::header::{HeaderName, HeaderValue};
|
|
|
|
use serde::{ser::Serializer, Deserialize, Serialize};
|
|
|
|
use serde::{ser::Serializer, Deserialize, Serialize};
|
|
|
|
use tauri::{
|
|
|
|
use tauri::{
|
|
|
|
api::ipc::{format_callback, CallbackFn},
|
|
|
|
api::ipc::{format_callback, CallbackFn},
|
|
|
@ -9,6 +10,7 @@ use tokio::{net::TcpStream, sync::Mutex};
|
|
|
|
use tokio_tungstenite::{
|
|
|
|
use tokio_tungstenite::{
|
|
|
|
connect_async_with_config,
|
|
|
|
connect_async_with_config,
|
|
|
|
tungstenite::{
|
|
|
|
tungstenite::{
|
|
|
|
|
|
|
|
client::IntoClientRequest,
|
|
|
|
protocol::{CloseFrame as ProtocolCloseFrame, WebSocketConfig},
|
|
|
|
protocol::{CloseFrame as ProtocolCloseFrame, WebSocketConfig},
|
|
|
|
Message,
|
|
|
|
Message,
|
|
|
|
},
|
|
|
|
},
|
|
|
@ -17,8 +19,6 @@ use tokio_tungstenite::{
|
|
|
|
|
|
|
|
|
|
|
|
use std::collections::HashMap;
|
|
|
|
use std::collections::HashMap;
|
|
|
|
use std::str::FromStr;
|
|
|
|
use std::str::FromStr;
|
|
|
|
use tauri::http::header::{HeaderName, HeaderValue};
|
|
|
|
|
|
|
|
use tokio_tungstenite::tungstenite::client::IntoClientRequest;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
type Id = u32;
|
|
|
|
type Id = u32;
|
|
|
|
type WebSocket = WebSocketStream<MaybeTlsStream<TcpStream>>;
|
|
|
|
type WebSocket = WebSocketStream<MaybeTlsStream<TcpStream>>;
|
|
|
|