Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 271 - 280 of 956 for results2 (0.07 seconds)

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

  1. internal/grid/grid_test.go

    		defer close(stream.Requests)
    		for i := range payloads {
    			// t.Log("sending new client request")
    			stream.Requests <- &testRequest{Num: i, String: testPayload}
    		}
    	}()
    	var n int
    	err = stream.Results(func(resp *testResponse) error {
    		const wantString = testPayload + testPayload
    		if resp.OrgString != testPayload+testPayload {
    			t.Errorf("want %q, got %q", wantString, resp.OrgString)
    		}
    		if resp.OrgNum != n+1 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 36.1K bytes
    - Click Count (0)
  2. internal/grid/handlers.go

    	Requests chan<- Req
    }
    
    // Results returns the results from the remote server one by one.
    // If any error is returned by the callback, the stream will be canceled.
    // If the context is canceled, the stream will be canceled.
    func (s *TypedStream[Req, Resp]) Results(next func(resp Resp) error) (err error) {
    	return s.responses.Results(func(b []byte) error {
    		resp := s.newResp()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 27.7K bytes
    - Click Count (0)
  3. android/guava-testlib/src/com/google/common/util/concurrent/testing/MockFutureListener.java

      /**
       * Verify that the listener completes in a reasonable amount of time, and Asserts that the future
       * returns the expected data.
       *
       * @throws Throwable if the listener isn't called or if it resulted in a throwable or if the
       *     result doesn't match the expected value.
       */
      public void assertSuccess(Object expectedData) throws Throwable {
        // Verify that the listener executed in a reasonable amount of time.
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri May 12 18:12:42 GMT 2023
    - 3K bytes
    - Click Count (0)
  4. src/main/java/org/codelibs/fess/util/DocList.java

     * This class extends ArrayList to hold document maps while tracking content size
     * and processing time metrics. It's used throughout the Fess search system to
     * manage collections of search results and crawled documents.
     *
     */
    public class DocList extends ArrayList<Map<String, Object>> {
    
        /** Serial version UID for serialization */
        private static final long serialVersionUID = 1L;
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 3.2K bytes
    - Click Count (0)
  5. src/test/java/org/codelibs/fess/job/PurgeDocJobTest.java

            // Execute the job multiple times
            String result1 = purgeDocJob.execute();
    
            // Reset the flag
            deleteByQueryCalled = false;
    
            String result2 = purgeDocJob.execute();
    
            // Assert both executions were successful
            assertEquals("", result1);
            assertEquals("", result2);
            assertTrue(deleteByQueryCalled);
        }
    
        @Test
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 16.4K bytes
    - Click Count (0)
  6. callbacks/preload.go

    				joinFieldValues[idx], _ = field.ValueOf(tx.Statement.Context, joinIndexValue)
    			}
    
    			if results, ok := joinIdentityMap[utils.ToStringKey(fieldValues...)]; ok {
    				joinKey := utils.ToStringKey(joinFieldValues...)
    				identityMap[joinKey] = append(identityMap[joinKey], results...)
    			}
    		}
    
    		_, foreignValues = schema.GetIdentityFieldValuesMap(tx.Statement.Context, joinResults, joinRelForeignFields)
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Sun May 25 07:40:40 GMT 2025
    - 11.7K bytes
    - Click Count (0)
  7. src/main/java/org/codelibs/fess/suggest/request/suggest/SuggestRequest.java

     *   <li>Building the query and filter query for the suggestion request.</li>
     *   <li>Processing the request and handling the response or failure.</li>
     *   <li>Creating the response from the search results.</li>
     * </ul>
     *
     * <p>Example usage:</p>
     * <pre>
     * SuggestRequest suggestRequest = new SuggestRequest();
     * suggestRequest.setIndex("my_index");
     * suggestRequest.setQuery("example query");
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Sat Mar 14 02:35:38 GMT 2026
    - 13.5K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/math/Quantiles.java

     *
     * <p>The definition of the kth q-quantile of N values is as follows: define x = k * (N - 1) / q; if
     * x is an integer, the result is the value which would appear at index x in the sorted dataset
     * (unless there are {@link Double#NaN NaN} values, see below); otherwise, the result is the average
     * of the values which would appear at the indexes floor(x) and ceil(x) weighted by (1-frac(x)) and
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 23 21:06:42 GMT 2026
    - 30.1K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/collect/FluentIterable.java

     * as a {@code List}:
     *
     * {@snippet :
     * ImmutableList<String> results =
     *     FluentIterable.from(database.getClientList())
     *         .filter(Client::isActiveInLastMonth)
     *         .transform(Object::toString)
     *         .limit(10)
     *         .toList();
     * }
     *
     * The approximate stream equivalent is:
     *
     * {@snippet :
     * List<String> results =
     *     database.getClientList()
     *         .stream()
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Apr 02 14:49:41 GMT 2026
    - 34.7K bytes
    - Click Count (0)
  10. guava/src/com/google/common/collect/FluentIterable.java

     * as a {@code List}:
     *
     * {@snippet :
     * ImmutableList<String> results =
     *     FluentIterable.from(database.getClientList())
     *         .filter(Client::isActiveInLastMonth)
     *         .transform(Object::toString)
     *         .limit(10)
     *         .toList();
     * }
     *
     * The approximate stream equivalent is:
     *
     * {@snippet :
     * List<String> results =
     *     database.getClientList()
     *         .stream()
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Apr 02 14:49:41 GMT 2026
    - 34.7K bytes
    - Click Count (0)
Back to Top