Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 61 - 70 of 377 for acceptCh (0.04 seconds)

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

  1. guava/src/com/google/common/util/concurrent/ExecutionError.java

       * `public final Error getCause()`.)
       */
    
      /**
       * Creates a new instance with {@code null} as its detail message and no cause.
       *
       * @deprecated Prefer {@linkplain ExecutionError(Error)} a constructor that accepts a cause: Users
       *     of this class typically expect for instances to have a non-null cause. At the moment, you
       *     can <i>usually</i> still preserve behavior by passing an explicit {@code null} cause. Note,
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Feb 13 17:34:21 GMT 2025
    - 4K bytes
    - Click Count (0)
  2. guava-testlib/src/com/google/common/collect/testing/SpliteratorTester.java

              forEach(prefix, consumer);
            }
            long size = spliterator.getExactSizeIfKnown();
            long[] counter = {0};
            spliterator.forEachRemaining(
                e -> {
                  consumer.accept(e);
                  counter[0]++;
                });
            if (size >= 0) {
              assertEquals(size, counter[0]);
            }
          }
        },
        ALTERNATE_ADVANCE_AND_SPLIT {
          @Override
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 15:50:50 GMT 2025
    - 12.1K bytes
    - Click Count (0)
  3. android/guava-testlib/src/com/google/common/collect/testing/SpliteratorTester.java

              forEach(prefix, consumer);
            }
            long size = spliterator.getExactSizeIfKnown();
            long[] counter = {0};
            spliterator.forEachRemaining(
                e -> {
                  consumer.accept(e);
                  counter[0]++;
                });
            if (size >= 0) {
              assertEquals(size, counter[0]);
            }
          }
        },
        ALTERNATE_ADVANCE_AND_SPLIT {
          @Override
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 15:50:50 GMT 2025
    - 12.5K bytes
    - Click Count (0)
  4. src/bufio/net_test.go

    	}
    
    	// Start a goroutine for the server to accept one connection
    	// and read all the data sent on the connection,
    	// reporting the number of bytes read on ch.
    	ch := make(chan int, 1)
    	var wg sync.WaitGroup
    	wg.Add(1)
    	go func() {
    		defer wg.Done()
    
    		tot := 0
    		defer func() {
    			ch <- tot
    		}()
    
    		serverConn, err := server.Accept()
    		if err != nil {
    			t.Error(err)
    			return
    		}
    
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Fri Feb 07 19:37:07 GMT 2025
    - 1.9K bytes
    - Click Count (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketHttpTest.kt

      fun missingConnectionHeader() {
        webServer.enqueue(
          MockResponse
            .Builder()
            .code(101)
            .setHeader("Upgrade", "websocket")
            .setHeader("Sec-WebSocket-Accept", "ujmZX4KXZqjwy6vi1aQFH5p4Ygk=")
            .build(),
        )
        webServer.enqueue(
          MockResponse
            .Builder()
            .onRequestStart(CloseSocket())
            .build(),
        )
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 35.5K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/util/concurrent/ExecutionError.java

       * `public final Error getCause()`.)
       */
    
      /**
       * Creates a new instance with {@code null} as its detail message and no cause.
       *
       * @deprecated Prefer {@linkplain ExecutionError(Error)} a constructor that accepts a cause: Users
       *     of this class typically expect for instances to have a non-null cause. At the moment, you
       *     can <i>usually</i> still preserve behavior by passing an explicit {@code null} cause. Note,
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Feb 13 17:34:21 GMT 2025
    - 4K bytes
    - Click Count (0)
  7. android/guava-testlib/src/com/google/common/collect/testing/OneSizeTestContainerGenerator.java

    import com.google.common.collect.testing.features.CollectionSize;
    import java.util.Collection;
    import org.jspecify.annotations.NullMarked;
    import org.jspecify.annotations.Nullable;
    
    /**
     * The subject-generator interface accepted by Collection testers, for testing a Collection at one
     * particular {@link CollectionSize}.
     *
     * <p>This interface should not be implemented outside this package; {@link
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 1.5K bytes
    - Click Count (0)
  8. build-logic/binary-compatibility/src/main/groovy/gradlebuild/binarycompatibility/rules/AcceptedRegressionsRulePostProcess.java

            left.removeAll(seenApiChanges);
            if (!left.isEmpty()) {
                String formattedLeft = CollectionUtils.join("\n", left);
                throw new RuntimeException("The following regressions are declared as accepted, but didn't match any rule:\n\n" + formattedLeft);
            }
        }
    
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Wed Jun 09 08:16:49 GMT 2021
    - 1.7K bytes
    - Click Count (0)
  9. build-logic/binary-compatibility/src/main/kotlin/gradlebuild/binarycompatibility/SortAcceptedApiChangesTask.kt

    import com.google.gson.Gson
    import com.google.gson.GsonBuilder
    import org.gradle.api.tasks.CacheableTask
    import org.gradle.api.tasks.TaskAction
    
    
    /**
     * This [Task][org.gradle.api.Task] reorders the changes in an accepted API changes files
     * so that they are alphabetically sorted (by type, then member).
     */
    @CacheableTask
    abstract class SortAcceptedApiChangesTask : AbstractAcceptedApiChangesMaintenanceTask() {
    
        @TaskAction
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Wed Apr 09 14:09:16 GMT 2025
    - 1.5K bytes
    - Click Count (0)
  10. impl/maven-core/src/main/java/org/apache/maven/logging/LoggingOutputStream.java

                ProjectBuildLogAppender.updateMdc();
                consumer.accept(line);
                buf.reset();
            }
        }
    
        public void forceFlush() {
            if (buf.size() > 0) {
                String line = new String(buf.toByteArray(), 0, buf.size());
                ProjectBuildLogAppender.updateMdc();
                consumer.accept(line);
                buf.reset();
            }
        }
    
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Wed Feb 12 12:31:43 GMT 2025
    - 3K bytes
    - Click Count (0)
Back to Top