From faad1d92b06151d4f3b2494c5c6186e35dbfb85a Mon Sep 17 00:00:00 2001 From: Nikolay Martynov Date: Wed, 24 Oct 2018 15:13:21 -0400 Subject: [PATCH] Clarify output of Hystrix test --- .../src/test/groovy/HystrixTest.groovy | 20 +++++++++---------- 1 file changed, 10 insertions(+), 10 deletions(-) diff --git a/dd-java-agent/instrumentation/hystrix-1.4/src/test/groovy/HystrixTest.groovy b/dd-java-agent/instrumentation/hystrix-1.4/src/test/groovy/HystrixTest.groovy index 0ca7682e4e..bd67953924 100644 --- a/dd-java-agent/instrumentation/hystrix-1.4/src/test/groovy/HystrixTest.groovy +++ b/dd-java-agent/instrumentation/hystrix-1.4/src/test/groovy/HystrixTest.groovy @@ -74,11 +74,11 @@ class HystrixTest extends AgentTestRunner { } where: - action | operation - "execute" | { HystrixCommand cmd -> cmd.execute() } - "queue" | { HystrixCommand cmd -> cmd.queue().get() } - "observe" | { HystrixCommand cmd -> cmd.observe().toBlocking().first() } - "observe" | { HystrixCommand cmd -> + action | operation + "execute" | { HystrixCommand cmd -> cmd.execute() } + "queue" | { HystrixCommand cmd -> cmd.queue().get() } + "observe" | { HystrixCommand cmd -> cmd.observe().toBlocking().first() } + "observe block" | { HystrixCommand cmd -> BlockingQueue queue = new LinkedBlockingQueue() cmd.observe().subscribe { next -> queue.put(next) @@ -147,11 +147,11 @@ class HystrixTest extends AgentTestRunner { } where: - action | operation - "execute" | { HystrixCommand cmd -> cmd.execute() } - "queue" | { HystrixCommand cmd -> cmd.queue().get() } - "observe" | { HystrixCommand cmd -> cmd.observe().toBlocking().first() } - "observe" | { HystrixCommand cmd -> + action | operation + "execute" | { HystrixCommand cmd -> cmd.execute() } + "queue" | { HystrixCommand cmd -> cmd.queue().get() } + "observe" | { HystrixCommand cmd -> cmd.observe().toBlocking().first() } + "observe block" | { HystrixCommand cmd -> BlockingQueue queue = new LinkedBlockingQueue() cmd.observe().subscribe { next -> queue.put(next)