complete spray client instrumentation with experimental branch

1 files changed, 12 insertions, 2 deletions

diff --git a/kamon-core/src/main/scala/test/SimpleRequestProcessor.scala b/kamon-core/src/main/scala/test/SimpleRequestProcessor.scala
index 7d4cec52..ef657f24 100644
--- a/kamon-core/src/main/scala/test/SimpleRequestProcessor.scala
+++ b/kamon-core/src/main/scala/test/SimpleRequestProcessor.scala
@@ -24,8 +24,12 @@ object SimpleRequestProcessor extends App with SimpleRoutingApp with RequestBuil
   startServer(interface = "localhost", port = 9090) {
     get {
       path("test"){
-        complete {
-          pipeline(Get("http://www.despegar.com.ar")).map(r => "Ok")
+        uow {
+          complete {
+            val futures = pipeline(Get("http://10.254.10.57:8000/")).map(r => "Ok") :: pipeline(Get("http://10.254.10.57:8000/")).map(r => "Ok") :: Nil
+
+            Future.sequence(futures).map(l => "Ok")
+          }
         }
       } ~
       path("reply" / Segment) { reqID =>
@@ -45,6 +49,12 @@ object SimpleRequestProcessor extends App with SimpleRoutingApp with RequestBuil
         dynamic {
           complete(Future { "OK" })
         }
+      } ~
+      path("error") {
+        complete {
+          throw new NullPointerException
+          "okk"
+        }
       }
     }
   }