ExampleOfUsingIt.scala

def getDeviceStatus(deviceId: DeviceId): Task[DeviceServiceError \/ DeviceState] = {
  websockets.publishWithResponse[StatusResponseMessage](DeviceMessage(deviceId, StatusUpdateRequestMessage))
    .map(_.leftMap[DeviceServiceError](WsError.apply))
    .flatMap  {
      case \/-(res) =>
        val state = DeviceState(DeviceStateId.random, deviceId, res.cameras.map(CameraStatus.fromCameraStatusDto), DeviceStatus.fromDeviceStatusDto(res.device), Instant.now())
        databaseDeviceService.updateDeviceState(deviceId, state)
      case -\/(err) => Task.apply(-\/(err))
    }
}

WebSocketService.scala

def publishWithResponse[A <: DeviceResponsePayload : DecodeJson](deviceMessage: DeviceMessage): Task[\/[WebSocketServiceError, A]] = {
  val handleSessionNotFound: Task[ WebSocketServiceError \/ ResponseMessage] = server.publishWithResponse(deviceMessage)
    .map(_.toRightDisjunction(SessionNotFoundWebSocketError(deviceMessage.deviceId)))

  val liftedErrors = handleSessionNotFound.timed(timeout).attempt.map { x =>
    x.leftMap[WebSocketServiceError](r => liftError(r, deviceMessage.deviceId))
  }.map(_.flatMap(identity))

  liftedErrors.map { y =>
    y.flatMap { x =>
      x.payload.as[A].toDisjunction.leftMap[WebSocketServiceError] {
        case (message, history) => UnableToParseResponsePayloadError(deviceMessage.deviceId, message)
      }
    }
  }
}