We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent e6397f3 commit 3e5d0acCopy full SHA for 3e5d0ac
1 file changed
src/common/websocket.rs
@@ -121,6 +121,7 @@ impl WebSocketConnector {
121
Ok(ws_stream)
122
}
123
124
+ #[cfg(feature = "sinks-websocket")]
125
pub(crate) async fn connect_backoff(&self) -> WebSocketStream<MaybeTlsStream<TcpStream>> {
126
let mut backoff = ExponentialBackoff::default();
127
@@ -142,6 +143,7 @@ impl WebSocketConnector {
142
143
144
/// Connects with exponential backoff, applying a timeout to each individual connection attempt.
145
/// This will retry forever until a connection is established.
146
+ #[cfg(feature = "sources-websocket")]
147
pub(crate) async fn connect_backoff_with_timeout(
148
&self,
149
timeout_duration: Duration,
0 commit comments