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 efc8691 commit 0e7a9e1Copy full SHA for 0e7a9e1
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