open-telemetry
/
opentelemetry-java-instrumentation
mirror of https://github.com/open-telemetry/opentelemetry-java-instrumentation.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Clarify output of Hystrix test

This commit is contained in:
Nikolay Martynov 2018-10-24 15:13:21 -04:00
parent 601993fcb4
commit faad1d92b0
1 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
dd-java-agent/instrumentation/hystrix-1.4/src/test/groovy/HystrixTest.groovy
View File

@ -74,11 +74,11 @@ class HystrixTest extends AgentTestRunner {
} }
where: where:
action | operation action | operation
"execute" | { HystrixCommand cmd -> cmd.execute() } "execute" | { HystrixCommand cmd -> cmd.execute() }
"queue" | { HystrixCommand cmd -> cmd.queue().get() } "queue" | { HystrixCommand cmd -> cmd.queue().get() }
"observe" | { HystrixCommand cmd -> cmd.observe().toBlocking().first() } "observe" | { HystrixCommand cmd -> cmd.observe().toBlocking().first() }
"observe" | { HystrixCommand cmd -> "observe block" | { HystrixCommand cmd ->
BlockingQueue queue = new LinkedBlockingQueue() BlockingQueue queue = new LinkedBlockingQueue()
cmd.observe().subscribe { next -> cmd.observe().subscribe { next ->
queue.put(next) queue.put(next)
@ -147,11 +147,11 @@ class HystrixTest extends AgentTestRunner {
} }
where: where:
action | operation action | operation
"execute" | { HystrixCommand cmd -> cmd.execute() } "execute" | { HystrixCommand cmd -> cmd.execute() }
"queue" | { HystrixCommand cmd -> cmd.queue().get() } "queue" | { HystrixCommand cmd -> cmd.queue().get() }
"observe" | { HystrixCommand cmd -> cmd.observe().toBlocking().first() } "observe" | { HystrixCommand cmd -> cmd.observe().toBlocking().first() }
"observe" | { HystrixCommand cmd -> "observe block" | { HystrixCommand cmd ->
BlockingQueue queue = new LinkedBlockingQueue() BlockingQueue queue = new LinkedBlockingQueue()
cmd.observe().subscribe { next -> cmd.observe().subscribe { next ->
queue.put(next) queue.put(next)