Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 841 - 850 of 1,135 for rejects (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. src/test/java/jcifs/SmbResourceLocatorTest.java

                assertEquals("server/", root.getName());
            }
        }
    
        @Mock
        DfsReferralData dfs;
        @Mock
        Address addr;
    
        @Test
        @DisplayName("Mockito interaction – dependent objects are called appropriately")
        void testInteractionsWithStubbedDependencies() throws Exception {
            String url = "smb://server/share/";
            DummySmbResourceLocator loc = new DummySmbResourceLocator(url);
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 8K bytes
    - Click Count (0)
  2. docs/en/docs/tutorial/background-tasks.md

    But if you need to access variables and objects from the same **FastAPI** app, or you need to perform small background tasks (like sending an email notification), you can simply just use `BackgroundTasks`.
    
    ## Recap { #recap }
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 4.7K bytes
    - Click Count (0)
  3. internal/bucket/bandwidth/monitor.go

    	mlock sync.RWMutex // mutex for bucket measurement
    
    	bucketsThrottle    map[BucketOptions]*bucketThrottle
    	bucketsMeasurement map[BucketOptions]*bucketMeasurement // Buckets with objects in flight
    
    	bucketMovingAvgTicker *time.Ticker    // Ticker for calculating moving averages
    	ctx                   context.Context // Context for generate
    	NodeCount             uint64
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 6K bytes
    - Click Count (0)
  4. internal/s3select/simdj/reader.go

    		readCloser.Close()
    		for range r.input {
    			// Read until EOF trickles through.
    			// Otherwise, we risk the decoder hanging.
    		}
    		r.readerWg.Done()
    	}
    
    	// We cannot reuse as we are sending parsed objects elsewhere.
    	simdjson.ParseNDStream(readCloser, r.input, nil)
    	r.readerWg.Add(1)
    	go r.startReader()
    	return &r
    }
    
    // NewElementReader - creates new JSON reader using readCloser.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 30 17:02:22 GMT 2023
    - 4.9K bytes
    - Click Count (0)
  5. src/main/java/org/codelibs/fess/llm/LlmClientManager.java

                throw new LlmException("LLM client is not available");
            }
            return client;
        }
    
        // RAG workflow delegation methods
    
        /**
         * Detects the intent of a user message using the configured LLM client.
         *
         * @param userMessage the user's message
         * @return the detected intent with extracted keywords
         * @throws LlmException if LLM is not available
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 19 11:10:51 GMT 2026
    - 17.4K bytes
    - Click Count (0)
  6. guava-tests/test/com/google/common/collect/AbstractHashFloodingTest.java

                },
                Math::log);
    
        abstract void apply(T collection, Object query);
    
        abstract double expectedAsymptotic(int n);
      }
    
      /**
       * Returns a list of objects with the same hash code, of size 2^power, counting calls to equals,
       * hashCode, and compareTo in counter.
       */
      private static List<CountsHashCodeAndEquals> createAdversarialInput(
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 9K bytes
    - Click Count (0)
  7. cmd/object-api-multipart_test.go

    		{bucketNames[1], "min", "minio-object-1.txt", uploadIDs[1], "", 10, listMultipartResults[24], nil, true},
    		// Test case for bucket with multiple objects in it.
    		// Bucket used : `bucketNames[2]`.
    		// Objects used: `objectNames[1-5]`.
    		// UploadId's used: uploadIds[4-8].
    		// (Test number 39).
    		{bucketNames[2], "", "", "", "", 100, listMultipartResults[25], nil, true},
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 89.4K bytes
    - Click Count (0)
  8. src/test/java/jcifs/pac/PacLogonInfoTest.java

            // Should validate string length
            String result = unicodeString.check(testString);
            assertEquals(testString, result);
    
            // Should reject wrong length
            assertThrows(PACDecodingException.class, () -> {
                unicodeString.check("WRONGLENGTH");
            });
        }
    
        @Test
        @DisplayName("Test empty arrays using mock")
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 12.3K bytes
    - Click Count (0)
  9. src/test/java/org/codelibs/fess/util/RenderDataUtilTest.java

            obj.setValue("complex value");
    
            RenderDataUtil.register(data, "complex", obj);
    
            Object result = data.getDataMap().get("complex");
            assertEquals(obj, result); // Non-entity objects are registered as-is
        }
    
        @Test
        public void test_register_arrayList() {
            RenderData data = new RenderData();
    
            BsUser entity1 = new BsUser();
            entity1.setName("user1");
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 9.2K bytes
    - Click Count (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/JdkFutureAdaptersTest.java

        /*
         * Don't shut down until the listenInPoolThread task has been accepted to
         * run. We want to see what happens when it's interrupted, not when it's
         * rejected.
         */
        submitSuccessful.await();
        executorService.shutdownNow();
        abstractFuture.set(DATA1);
        assertThat(listenableFuture.get()).isEqualTo(DATA1);
        singleCallListener.waitForCall();
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 10K bytes
    - Click Count (0)
Back to Top