aboutsummaryrefslogtreecommitdiff
path: root/src/main/scala/xyz/driver/core/rest/HttpRestServiceTransport.scala
diff options
context:
space:
mode:
authorZach Smith <zach@driver.xyz>2017-10-31 09:09:13 -0700
committerZach Smith <zach@driver.xyz>2017-10-31 09:19:04 -0700
commitc4fc9d9496ba382eb371a65860caf2cd49261a06 (patch)
tree84e458c896a9aa2322c9a3c9600ac2a56e2dd433 /src/main/scala/xyz/driver/core/rest/HttpRestServiceTransport.scala
parent5f3330ffd4df8d87b97d88789aced1b1b8f7410d (diff)
downloaddriver-core-c4fc9d9496ba382eb371a65860caf2cd49261a06.tar.gz
driver-core-c4fc9d9496ba382eb371a65860caf2cd49261a06.tar.bz2
driver-core-c4fc9d9496ba382eb371a65860caf2cd49261a06.zip
Change transformWith to recoverWith
Diffstat (limited to 'src/main/scala/xyz/driver/core/rest/HttpRestServiceTransport.scala')
-rw-r--r--src/main/scala/xyz/driver/core/rest/HttpRestServiceTransport.scala10
1 files changed, 5 insertions, 5 deletions
diff --git a/src/main/scala/xyz/driver/core/rest/HttpRestServiceTransport.scala b/src/main/scala/xyz/driver/core/rest/HttpRestServiceTransport.scala
index 2bec4c3..376b154 100644
--- a/src/main/scala/xyz/driver/core/rest/HttpRestServiceTransport.scala
+++ b/src/main/scala/xyz/driver/core/rest/HttpRestServiceTransport.scala
@@ -58,11 +58,11 @@ class HttpRestServiceTransport(applicationName: Name[App],
log.warn(s"Failed to receive response from ${request.method} ${request.uri} in $responseLatency ms", t)
}(executionContext)
- response.transformWith {
- case Success(r) => Future.successful(r)
- case Failure(_: TcpIdleTimeoutException) =>
- Future.failed(ExternalServiceTimeoutException())
- case Failure(t: Throwable) => Future.failed(t)
+ response.recoverWith {
+ case _: TcpIdleTimeoutException =>
+ val serviceCalled = s"${requestStub.method} ${requestStub.uri}"
+ Future.failed(ExternalServiceTimeoutException(serviceCalled))
+ case t: Throwable => Future.failed(t)
}
}