aboutsummaryrefslogtreecommitdiff
path: root/src/main/scala/xyz/driver/pdsuicommon/http/AsyncHttpClientFetcher.scala
diff options
context:
space:
mode:
authorvlad <vlad@driver.xyz>2017-06-16 11:12:52 -0700
committervlad <vlad@driver.xyz>2017-06-16 11:12:52 -0700
commit111311fd935d9bd271c673cf10c0babe54bde8a6 (patch)
tree4742679ca244bb417e3d8fdacd51f269f4b969ae /src/main/scala/xyz/driver/pdsuicommon/http/AsyncHttpClientFetcher.scala
parentc1993e0f834cb4e0ccfd1dd54610ffe50de60238 (diff)
downloadrest-query-111311fd935d9bd271c673cf10c0babe54bde8a6.tar.gz
rest-query-111311fd935d9bd271c673cf10c0babe54bde8a6.tar.bz2
rest-query-111311fd935d9bd271c673cf10c0babe54bde8a6.zip
Update PDS UI common code to be up to datev0.1.5
Diffstat (limited to 'src/main/scala/xyz/driver/pdsuicommon/http/AsyncHttpClientFetcher.scala')
-rw-r--r--src/main/scala/xyz/driver/pdsuicommon/http/AsyncHttpClientFetcher.scala24
1 files changed, 13 insertions, 11 deletions
diff --git a/src/main/scala/xyz/driver/pdsuicommon/http/AsyncHttpClientFetcher.scala b/src/main/scala/xyz/driver/pdsuicommon/http/AsyncHttpClientFetcher.scala
index 3f99d2a..d836b9d 100644
--- a/src/main/scala/xyz/driver/pdsuicommon/http/AsyncHttpClientFetcher.scala
+++ b/src/main/scala/xyz/driver/pdsuicommon/http/AsyncHttpClientFetcher.scala
@@ -40,17 +40,19 @@ class AsyncHttpClientFetcher(settings: AsyncHttpClientFetcher.Settings)
logger.info("{}, apply({})", fingerPrint, url)
val promise = Promise[Response]()
- httpClient.prepareGet(url.toString).execute(new AsyncCompletionHandler[Response] {
- override def onCompleted(response: Response): Response = {
- promise.success(response)
- response
- }
-
- override def onThrowable(t: Throwable): Unit = {
- promise.failure(t)
- super.onThrowable(t)
- }
- })
+ httpClient
+ .prepareGet(url.toString)
+ .execute(new AsyncCompletionHandler[Response] {
+ override def onCompleted(response: Response): Response = {
+ promise.success(response)
+ response
+ }
+
+ override def onThrowable(t: Throwable): Unit = {
+ promise.failure(t)
+ super.onThrowable(t)
+ }
+ })
// Promises have their own ExecutionContext
// So, we have to hack it.