Queue should block.
This commit is contained in:
parent
e3aae4e869
commit
122c482dd5
|
@ -161,7 +161,7 @@ class HystrixTest extends AgentTestRunner {
|
||||||
cmd.observe().subscribe { next ->
|
cmd.observe().subscribe { next ->
|
||||||
queue.put(next)
|
queue.put(next)
|
||||||
}
|
}
|
||||||
queue.poll()
|
queue.take()
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue