diff options
| author | John St John <johnthesaintjohn@gmail.com> | 2017-10-05 12:38:09 -0700 |
|---|---|---|
| committer | Jakob Odersky <jakob@odersky.com> | 2017-10-05 12:59:09 -0700 |
| commit | 388842a4afab4d88ae9ea110a310cc72f840a71a (patch) | |
| tree | f8eea22694b05a83b371cf1a3d5f779cc472ba79 | |
| parent | 7ab412e4bc03fbddd12c2a010076d4242c5c38ca (diff) | |
| download | tracing-388842a4afab4d88ae9ea110a310cc72f840a71a.tar.gz tracing-388842a4afab4d88ae9ea110a310cc72f840a71a.tar.bz2 tracing-388842a4afab4d88ae9ea110a310cc72f840a71a.zip | |
remove trace/span header from passed headers prior to adding new headers
| -rw-r--r-- | src/main/scala/TracingDirectives.scala | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/src/main/scala/TracingDirectives.scala b/src/main/scala/TracingDirectives.scala index a172808..34f9c82 100644 --- a/src/main/scala/TracingDirectives.scala +++ b/src/main/scala/TracingDirectives.scala @@ -51,7 +51,12 @@ trait TracingDirectives { RawHeader(SpanHeaderName, span.spanId.toString) ) - mapRequest(childRequest => childRequest.withHeaders(childHeaders)) & mapRouteResult { + mapRequest(childRequest => + childRequest + .withHeaders(childRequest.headers + .filterNot(h => + h.name() == TraceHeaderName || + h.name() == SpanHeaderName) ++ childHeaders)) & mapRouteResult { result => tracer.submit(span.end()) result |