Fix #288

.gitignore

@@ -6,6 +6,7 @@
 **/profile.json
 **/rustc-ice-*.txt
 **/target
+boringssl
 mdbook-target
 wtx-docs/book
 wtx-fuzz/artifacts

wtx-instances/generic-examples/client-api-framework.rs

@@ -16,13 +16,13 @@ use tokio::net::TcpStream;
 use wtx::{
   client_api_framework::{
     misc::{Pair, RequestLimit, RequestThrottling},
-    network::{transport::Transport, HttpParams, WsParams},
+    network::{transport::SendingRecievingTransport, HttpParams, WsParams},
     Api,
   },
   data_transformation::dnsn::SerdeJson,
   http::client_framework::ClientFrameworkTokio,
   misc::{simple_seed, Uri, Xorshift64},
-  web_socket::{WebSocketBuffer, WebSocketClient},
+  web_socket::{WebSocket, WebSocketBuffer},
 };
 
 wtx::create_packages_aux_wrapper!();
@@ -97,11 +97,11 @@ async fn http_pair(
 async fn web_socket_pair() -> wtx::Result<
   Pair<
     PkgsAux<GenericThrottlingApi, SerdeJson, WsParams>,
-    WebSocketClient<(), TcpStream, WebSocketBuffer>,
+    WebSocket<(), TcpStream, WebSocketBuffer, true>,
   >,
 > {
   let uri = Uri::new("ws://generic_web_socket_uri.com");
-  let web_socket = WebSocketClient::connect(
+  let web_socket = WebSocket::connect(
     (),
     [],
     false,

wtx-instances/src/bin/autobahn-client.rs

@@ -3,15 +3,15 @@
 use tokio::net::TcpStream;
 use wtx::{
   misc::{simple_seed, UriRef, Xorshift64},
-  web_socket::{compression::Flate2, Frame, OpCode, WebSocketBuffer, WebSocketClient},
+  web_socket::{compression::Flate2, Frame, OpCode, WebSocket, WebSocketBuffer},
 };
 
 #[tokio::main]
 async fn main() -> wtx::Result<()> {
   let host = "127.0.0.1:9080";
   let mut wsb = WebSocketBuffer::default();
   for case in 1..=get_case_count(host, &mut wsb).await? {
-    let mut ws = WebSocketClient::connect(
+    let mut ws = WebSocket::connect(
       Flate2::default(),
       [],
       false,
@@ -38,7 +38,7 @@ async fn main() -> wtx::Result<()> {
       }
     }
   }
-  WebSocketClient::connect(
+  WebSocket::connect(
     (),
     [],
     false,
@@ -54,7 +54,7 @@ async fn main() -> wtx::Result<()> {
 }
 
 async fn get_case_count(host: &str, wsb: &mut WebSocketBuffer) -> wtx::Result<u32> {
-  let mut ws = WebSocketClient::connect(
+  let mut ws = WebSocket::connect(
     (),
     [],
     false,