} catch (InterruptedException e) {
                throw UncheckedException.throwAsUncheckedException(e);
            }
            doReleaseAction(handler, yetToBeReceived);
        });
    }

    abstract void doReleaseAction(BlockingHttpServer.BlockingHandler handler, int yetToBeReceived);

        super(lock, testId, timeout, maxConcurrent, previous, expectedRequests, executor);
    }

    @Override
    void doReleaseAction(BlockingHttpServer.BlockingHandler handler, int yetToBeReceived) {
        if (yetToBeReceived > 0) {
            handler.release(1);
        } else {

        super(lock, testId, timeout, expectations.size(), previous, expectations, executor);
    }

    @Override
    void doReleaseAction(BlockingHttpServer.BlockingHandler handler, int yetToBeReceived) {
        handler.releaseAll();
    }