2021222324252627282930
mockInvocation(invocationFailure); if (recoveryFailure != null) mockRecovery(recoveryFailure); final Waiter waiter = new Waiter(); waiter.expectResume(); runInThread(new Runnable() { public void run() { try { performInvocation(); waiter.resume();
127128129130131132133134135136137
public void shouldNotBlockOpenWhenSyncAcquired() throws Throwable { circuit.open(); final Waiter waiter = new Waiter(); waiter.expectResume(); new Thread(new Runnable() { @Override public void run() { try { circuit.await();