Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for assertCanWait (0.12 sec)

  1. testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ResourceHandlerWrapper.java

        }
    
        @Override
        public String getMethod() {
            return handler.getMethod();
        }
    
        @Override
        public void assertCanWait() throws IllegalStateException {
            lock.lock();
            try {
                owner.assertCanWait();
                if (!autoRelease && !started) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 07:21:38 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  2. testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/WaitPrecondition.java

    /**
     * Some action that must be met before it is legal to wait for an incoming request.
     */
    interface WaitPrecondition {
        /**
         * Must be called under lock.
         */
        void assertCanWait() throws IllegalStateException;
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 07:21:38 UTC 2024
    - 892 bytes
    - Viewed (0)
  3. testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ExpectMethod.java

            }
            SendPartialResponseThenBlock block = new SendPartialResponseThenBlock(lock, timeout, new WaitPrecondition() {
                @Override
                public void assertCanWait() throws IllegalStateException {
                    ExpectMethod.this.precondition.assertCanWait();
                }
            }, content);
            replaceBody(block, block);
            return this;
        }
    
        @Override
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 07:21:38 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  4. testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ExpectInAnyOrder.java

            }
        }
    
        @Override
        public WaitPrecondition getWaitPrecondition() {
            return () -> {
                for (TrackingHttpHandler handler : expected) {
                    handler.getWaitPrecondition().assertCanWait();
                }
            };
        }
    
        @Override
        public void cancelBlockedRequests() {
            lock.lock();
            try {
                if (current != null) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 07:21:38 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  5. testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/SendPartialResponseThenBlock.java

            }
            exchange.getResponseBody().write(content, 1024, content.length - 1024);
        }
    
        @Override
        public void waitUntilBlocked() {
            lock.lock();
            try {
                precondition.assertCanWait();
                if (released) {
                    throw new IllegalStateException("Response has already been released.");
                }
    
                long now = clock.getCurrentTime();
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 07:21:38 UTC 2024
    - 4.7K bytes
    - Viewed (0)
Back to top