We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
WebSocketStream::get_config
1 parent 11790d7 commit 4d57961Copy full SHA for 4d57961
poem/src/web/websocket/stream.rs
@@ -6,7 +6,7 @@ use std::{
6
7
use futures_util::{Sink, SinkExt, Stream, StreamExt};
8
9
-use super::{utils::tungstenite_error_to_io_error, Message};
+use super::{utils::tungstenite_error_to_io_error, Message, WebSocketConfig};
10
use crate::Upgraded;
11
12
/// A `WebSocket` stream, which implements [`Stream<Message>`] and
@@ -19,6 +19,11 @@ impl WebSocketStream {
19
pub(crate) fn new(inner: tokio_tungstenite::WebSocketStream<Upgraded>) -> Self {
20
Self { inner }
21
}
22
+
23
+ /// Returns a reference to the configuration of the stream.
24
+ pub fn get_config(&self) -> &WebSocketConfig {
25
+ self.inner.get_config()
26
+ }
27
28
29
impl Stream for WebSocketStream {
0 commit comments