- Sort Score
- Result 10 results
- Languages All
Results 2901 - 2910 of 3,984 for Signal (0.17 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/UncheckedThrowingFuture.java
* SettableFuture}). * * <p>Useful for testing the behavior of Future utilities against odd futures. * * @author Anthony Zana */ @GwtCompatible @NullUnmarked final class UncheckedThrowingFuture<V> extends AbstractFuture<V> { public static <V> ListenableFuture<V> throwingError(Error error) { UncheckedThrowingFuture<V> future = new UncheckedThrowingFuture<V>();
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 3.3K bytes - Viewed (0) -
android/guava/src/com/google/common/graph/UndirectedGraphConnections.java
* An implementation of {@link GraphConnections} for undirected graphs. * * @author James Sexton * @param <N> Node parameter type * @param <V> Value parameter type */ final class UndirectedGraphConnections<N, V> implements GraphConnections<N, V> { private final Map<N, V> adjacentNodeValues; private UndirectedGraphConnections(Map<N, V> adjacentNodeValues) { this.adjacentNodeValues = checkNotNull(adjacentNodeValues); }Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 3.3K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/HashingOutputStream.java
import java.io.OutputStream; /** * An {@link OutputStream} that maintains a hash of the data written to it. * * @author Zoe Piepmeier * @since 16.0 */ @Beta public final class HashingOutputStream extends FilterOutputStream { private final Hasher hasher; /** * Creates an output stream that hashes using the given {@link HashFunction}, and forwards all * data written to it to the underlying {@link OutputStream}. *Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sat Dec 21 03:10:51 UTC 2024 - 2.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/DirectExecutorService.java
import java.util.concurrent.TimeUnit; /** See newDirectExecutorService javadoc for behavioral notes. */ @GwtIncompatible final class DirectExecutorService extends AbstractListeningExecutorService { /** Lock used whenever accessing the state variables (runningTasks, shutdown) of the executor */ private final Object lock = new Object(); /* * Conceptually, these two variables describe the executor being in * one of three states:Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Dec 16 14:23:59 UTC 2025 - 3.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FakeTimeLimiterTest.java
/** * Unit test for {@link FakeTimeLimiter}. * * @author Jens Nyman */ @NullUnmarked public class FakeTimeLimiterTest extends TestCase { private static final int DELAY_MS = 50; private static final String RETURN_VALUE = "abc"; private TimeLimiter timeLimiter; @Override protected void setUp() throws Exception { super.setUp(); timeLimiter = new FakeTimeLimiter(); }Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 4.1K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/base/AsciiBenchmark.java
/** * Benchmarks for the ASCII class. * * @author Kevin Bourrillion */ @NullUnmarked public class AsciiBenchmark { private static final String ALPHA = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz"; private static final String NONALPHA = "0123456789`~-_=+[]{}|;:',.<>/?!@#$%^&*()\"\\"; @Param({"20", "2000"}) int size; @Param({"2", "20"})Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 4.8K bytes - Viewed (0) -
docs/pt/docs/benchmarks.md
* Você não conseguiria escrever uma aplicação em Uvicorn diretamente. Isso significa que seu código deveria conter, mais ou menos, todo o código fornecido pelo Starlette (ou **FastAPI**). E se você fizesse isso, sua aplicação final poderia ter a mesma sobrecarga que utilizar um _framework_ que minimiza o código e _bugs_ da sua aplicação. * Se você quer fazer comparações com o Uvicorn, compare com Daphne, Hypercorn, uWSGI, etc. Servidores de Aplicação.
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Wed Nov 12 16:23:57 UTC 2025 - 3.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java
// without resorting to even crazier hacks to reset static final boolean fields. System.setProperty("guava.concurrent.generate_cancellation_cause", "true"); String concurrentPackage = SettableFuture.class.getPackage().getName(); classReloader = new URLClassLoader(ClassPathUtil.getClassPathUrls()) { @GuardedBy("loadedClasses") final Map<String, Class<?>> loadedClasses = new HashMap<>();Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Oct 28 16:03:47 UTC 2025 - 6.2K bytes - Viewed (0) -
build-logic/documentation/src/test/groovy/gradlebuild/docs/dsl/docbook/BasicJavadocLexerTest.groovy
* limitations under the License. */ package gradlebuild.docs.dsl.docbook import spock.lang.Specification class BasicJavadocLexerTest extends Specification { final BasicJavadocLexer lexer = new BasicJavadocLexer(new JavadocScanner("")) final visitor = Mock(JavadocLexer.TokenVisitor) def parsesHtmlElements() { when: lexer.pushText("<p> text </p>") lexer.visit(visitor) then:Registered: Wed Dec 31 11:36:14 UTC 2025 - Last Modified: Wed Dec 09 08:14:05 UTC 2020 - 6K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/suggest/SuggesterTest.java
indexResponse.getErrors(); suggester.refresh(); final SuggestResponse response = suggester.suggest().setQuery("検索").setSuggestDetail(true).execute().getResponse(); final List<SuggestItem> items = response.getItems(); assertEquals(1, response.getNum()); assertEquals("検索 エンジン", items.get(0).getText()); }
Registered: Sat Dec 20 13:04:59 UTC 2025 - Last Modified: Mon Nov 24 03:40:05 UTC 2025 - 37.4K bytes - Viewed (0)