aboutsummaryrefslogtreecommitdiff
path: root/src/main/scala/xyz/driver/pdsuicommon/http/AsyncHttpClientFetcher.scala
diff options
context:
space:
mode:
authorvlad <vlad@driver.xyz>2017-06-14 14:46:19 -0700
committervlad <vlad@driver.xyz>2017-06-14 14:46:19 -0700
commit7b8ac40ab6501ec53c5a55962fe4a3d54666ae8d (patch)
tree211a6a544facb278807d47cc3d91f0cee59f2466 /src/main/scala/xyz/driver/pdsuicommon/http/AsyncHttpClientFetcher.scala
parent59aababea4a8856ac972fe452b14003f82fe3706 (diff)
downloadrest-query-7b8ac40ab6501ec53c5a55962fe4a3d54666ae8d.tar.gz
rest-query-7b8ac40ab6501ec53c5a55962fe4a3d54666ae8d.tar.bz2
rest-query-7b8ac40ab6501ec53c5a55962fe4a3d54666ae8d.zip
Update for recent PDS UI changesv0.1.4
Diffstat (limited to 'src/main/scala/xyz/driver/pdsuicommon/http/AsyncHttpClientFetcher.scala')
-rw-r--r--src/main/scala/xyz/driver/pdsuicommon/http/AsyncHttpClientFetcher.scala25
1 files changed, 11 insertions, 14 deletions
diff --git a/src/main/scala/xyz/driver/pdsuicommon/http/AsyncHttpClientFetcher.scala b/src/main/scala/xyz/driver/pdsuicommon/http/AsyncHttpClientFetcher.scala
index d693019..3f99d2a 100644
--- a/src/main/scala/xyz/driver/pdsuicommon/http/AsyncHttpClientFetcher.scala
+++ b/src/main/scala/xyz/driver/pdsuicommon/http/AsyncHttpClientFetcher.scala
@@ -40,19 +40,17 @@ 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.
@@ -62,7 +60,6 @@ class AsyncHttpClientFetcher(settings: AsyncHttpClientFetcher.Settings)
if (response.getStatusCode == 200) {
// DO NOT LOG body, it could be PHI
- // logger.trace(response.getResponseBody())
val bytes = response.getResponseBodyAsBytes
logger.debug("{}, size is {}B", fingerPrint, bytes.size.asInstanceOf[AnyRef])
Future.successful(bytes)