chore: bump tungstenite from 0.14.0 to 0.15.0 (#19222)
* chore: bump tungstenite from 0.14.0 to 0.15.0 Bumps [tungstenite](https://github.com/snapview/tungstenite-rs) from 0.14.0 to 0.15.0. - [Release notes](https://github.com/snapview/tungstenite-rs/releases) - [Changelog](https://github.com/snapview/tungstenite-rs/blob/master/CHANGELOG.md) - [Commits](https://github.com/snapview/tungstenite-rs/compare/v0.14.0...v0.15.0) --- updated-dependencies: - dependency-name: tungstenite dependency-type: direct:production update-type: version-update:semver-minor ... Signed-off-by: dependabot[bot] <support@github.com> * [auto-commit] Update all Cargo lock files * Update stream type Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> Co-authored-by: dependabot-buildkite <anatoly+githubjenkins@solana.io> Co-authored-by: Tyera Eulberg <tyera@solana.com>
This commit is contained in:
parent
b64eeb7729
commit
74cc2e5ffa
|
@ -6881,9 +6881,9 @@ checksum = "e604eb7b43c06650e854be16a2a03155743d3752dd1c943f6829e26b7a36e382"
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "tungstenite"
|
name = "tungstenite"
|
||||||
version = "0.14.0"
|
version = "0.15.0"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "a0b2d8558abd2e276b0a8df5c05a2ec762609344191e5fd23e292c910e9165b5"
|
checksum = "983d40747bce878d2fb67d910dcb8bd3eca2b2358540c3cc1b98c027407a3ae3"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"base64 0.13.0",
|
"base64 0.13.0",
|
||||||
"byteorder",
|
"byteorder",
|
||||||
|
|
|
@ -34,7 +34,7 @@ solana-version = { path = "../version", version = "=1.8.0" }
|
||||||
solana-vote-program = { path = "../programs/vote", version = "=1.8.0" }
|
solana-vote-program = { path = "../programs/vote", version = "=1.8.0" }
|
||||||
thiserror = "1.0"
|
thiserror = "1.0"
|
||||||
tokio = { version = "1", features = ["full"] }
|
tokio = { version = "1", features = ["full"] }
|
||||||
tungstenite = "0.14.0"
|
tungstenite = "0.15.0"
|
||||||
url = "2.2.2"
|
url = "2.2.2"
|
||||||
|
|
||||||
[dev-dependencies]
|
[dev-dependencies]
|
||||||
|
|
|
@ -17,6 +17,7 @@ use {
|
||||||
solana_sdk::signature::Signature,
|
solana_sdk::signature::Signature,
|
||||||
std::{
|
std::{
|
||||||
marker::PhantomData,
|
marker::PhantomData,
|
||||||
|
net::TcpStream,
|
||||||
sync::{
|
sync::{
|
||||||
atomic::{AtomicBool, Ordering},
|
atomic::{AtomicBool, Ordering},
|
||||||
mpsc::{channel, Receiver},
|
mpsc::{channel, Receiver},
|
||||||
|
@ -25,7 +26,7 @@ use {
|
||||||
thread::JoinHandle,
|
thread::JoinHandle,
|
||||||
},
|
},
|
||||||
thiserror::Error,
|
thiserror::Error,
|
||||||
tungstenite::{client::AutoStream, connect, Message, WebSocket},
|
tungstenite::{connect, stream::MaybeTlsStream, Message, WebSocket},
|
||||||
url::{ParseError, Url},
|
url::{ParseError, Url},
|
||||||
};
|
};
|
||||||
|
|
||||||
|
@ -50,7 +51,7 @@ where
|
||||||
{
|
{
|
||||||
message_type: PhantomData<T>,
|
message_type: PhantomData<T>,
|
||||||
operation: &'static str,
|
operation: &'static str,
|
||||||
socket: Arc<RwLock<WebSocket<AutoStream>>>,
|
socket: Arc<RwLock<WebSocket<MaybeTlsStream<TcpStream>>>>,
|
||||||
subscription_id: u64,
|
subscription_id: u64,
|
||||||
t_cleanup: Option<JoinHandle<()>>,
|
t_cleanup: Option<JoinHandle<()>>,
|
||||||
exit: Arc<AtomicBool>,
|
exit: Arc<AtomicBool>,
|
||||||
|
@ -76,7 +77,7 @@ where
|
||||||
T: DeserializeOwned,
|
T: DeserializeOwned,
|
||||||
{
|
{
|
||||||
fn send_subscribe(
|
fn send_subscribe(
|
||||||
writable_socket: &Arc<RwLock<WebSocket<AutoStream>>>,
|
writable_socket: &Arc<RwLock<WebSocket<MaybeTlsStream<TcpStream>>>>,
|
||||||
body: String,
|
body: String,
|
||||||
) -> Result<u64, PubsubClientError> {
|
) -> Result<u64, PubsubClientError> {
|
||||||
writable_socket
|
writable_socket
|
||||||
|
@ -118,7 +119,7 @@ where
|
||||||
}
|
}
|
||||||
|
|
||||||
fn read_message(
|
fn read_message(
|
||||||
writable_socket: &Arc<RwLock<WebSocket<AutoStream>>>,
|
writable_socket: &Arc<RwLock<WebSocket<MaybeTlsStream<TcpStream>>>>,
|
||||||
) -> Result<T, PubsubClientError> {
|
) -> Result<T, PubsubClientError> {
|
||||||
let message = writable_socket.write().unwrap().read_message()?;
|
let message = writable_socket.write().unwrap().read_message()?;
|
||||||
let message_text = &message.into_text().unwrap();
|
let message_text = &message.into_text().unwrap();
|
||||||
|
|
|
@ -3806,9 +3806,9 @@ checksum = "e604eb7b43c06650e854be16a2a03155743d3752dd1c943f6829e26b7a36e382"
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "tungstenite"
|
name = "tungstenite"
|
||||||
version = "0.14.0"
|
version = "0.15.0"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "a0b2d8558abd2e276b0a8df5c05a2ec762609344191e5fd23e292c910e9165b5"
|
checksum = "983d40747bce878d2fb67d910dcb8bd3eca2b2358540c3cc1b98c027407a3ae3"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"base64 0.13.0",
|
"base64 0.13.0",
|
||||||
"byteorder 1.4.3",
|
"byteorder 1.4.3",
|
||||||
|
|
Loading…
Reference in New Issue