Skip to content

Commit 55ec54c

Browse files
committed
Use non deprecated config options (default is no buffering)
1 parent 7f40367 commit 55ec54c

File tree

1 file changed

+1
-4
lines changed

1 file changed

+1
-4
lines changed

src/sinks/websocket/sink.rs

+1-4
Original file line numberDiff line numberDiff line change
@@ -132,10 +132,7 @@ impl WebSocketConnector {
132132

133133
let maybe_tls = self.tls_connect().await?;
134134

135-
let ws_config = WebSocketConfig {
136-
max_send_queue: None, // don't buffer messages
137-
..Default::default()
138-
};
135+
let ws_config = WebSocketConfig::default();
139136

140137
let (ws_stream, _response) = client_async_with_config(request, maybe_tls, Some(ws_config))
141138
.await

0 commit comments

Comments
 (0)