Skip to content

Instantly share code, notes, and snippets.

@adamw
Created November 18, 2019 10:26
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save adamw/93f689c08e7f0bc596224951cf905903 to your computer and use it in GitHub Desktop.
Save adamw/93f689c08e7f0bc596224951cf905903 to your computer and use it in GitHub Desktop.
override def openWebsocket[T, WS_RESULT](
request: Request[T, S],
handler: WS_HANDLER[WS_RESULT]): F[WebSocketResponse[WS_RESULT]] = {
responseMonad.map(responseMonad.handleError(delegate.openWebsocket(request, handler)) {
case e: Exception =>
logger.error(s"Exception when opening websocket: $request", e)
responseMonad.error(e)
}) { response =>
logger.debug(s"Websocket open: $request, with response headers: ${response.headers}")
response
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment