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.
1 parent 5de1d40 commit d6d3c2cCopy full SHA for d6d3c2c
ws/src/main/scala/sttp/ws/WebSocket.scala
@@ -48,8 +48,8 @@ trait WebSocket[F[_]] {
48
*/
49
def receiveDataFrame(pongOnPing: Boolean = true): F[WebSocketFrame.Data[_]] =
50
receive().flatMap {
51
- case close: WebSocketFrame.Close => monad.error(WebSocketClosed(Some(close)))
52
- case d: WebSocketFrame.Data[_] => monad.unit(d)
+ case close: WebSocketFrame.Close => monad.error(WebSocketClosed(Some(close)))
+ case d: WebSocketFrame.Data[_] => monad.unit(d)
53
case WebSocketFrame.Ping(payload) if pongOnPing =>
54
send(WebSocketFrame.Pong(payload))
55
// https://github.com/softwaremill/sttp/issues/2236: after a Ping frame is received, the WS might have become
0 commit comments