Clarify output of Hystrix test
@@ -78,7 +78,7 @@ class HystrixTest extends AgentTestRunner {
"execute" | { HystrixCommand cmd -> cmd.execute() }
"queue" | { HystrixCommand cmd -> cmd.queue().get() }
"observe" | { HystrixCommand cmd -> cmd.observe().toBlocking().first() }
- "observe" | { HystrixCommand cmd ->
+ "observe block" | { HystrixCommand cmd ->
BlockingQueue queue = new LinkedBlockingQueue()
cmd.observe().subscribe { next ->
queue.put(next)
@@ -151,7 +151,7 @@ class HystrixTest extends AgentTestRunner {
"execute" | { HystrixCommand cmd -> cmd.execute() }
"queue" | { HystrixCommand cmd -> cmd.queue().get() }
"observe" | { HystrixCommand cmd -> cmd.observe().toBlocking().first() }
- "observe" | { HystrixCommand cmd ->
+ "observe block" | { HystrixCommand cmd ->
BlockingQueue queue = new LinkedBlockingQueue()
cmd.observe().subscribe { next ->
queue.put(next)
