- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 125 for Kistner (0.18 sec)
-
guava-tests/test/com/google/common/util/concurrent/AbstractChainedListenableFutureTest.java
protected SettableFuture<Integer> inputFuture; protected ListenableFuture<T> resultFuture; protected MockFutureListener listener; @Override protected void setUp() throws Exception { super.setUp(); inputFuture = SettableFuture.create(); resultFuture = buildChainingFuture(inputFuture); listener = new MockFutureListener(resultFuture); } public void testFutureGetBeforeCallback() throws Exception {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 3.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
void call(L listener); } /** * Adds a listener that will be called using the given executor when events are later {@link * #enqueue enqueued} and {@link #dispatch dispatched}. */ public void addListener(L listener, Executor executor) { checkNotNull(listener, "listener"); checkNotNull(executor, "executor"); listeners.add(new PerListenerQueue<>(listener, executor)); } /**
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 8.2K bytes - Viewed (0) -
build-logic/documentation/src/test/groovy/gradlebuild/docs/dsl/docbook/JavadocLinkConverterTest.groovy
final ClassMetaDataRepository<ClassMetaData> repository = Mock() final GenerationListener listener = Mock() final JavadocLinkConverter converter = new JavadocLinkConverter(document, nameResolver, linkRenderer, repository) def convertsClassNameToLink() { when: def link = converter.resolve('someName', classMetaData, listener) then: format(link) == '<someLinkElement/>'
Groovy - Registered: Wed Apr 17 11:36:08 GMT 2024 - Last Modified: Wed Dec 09 08:14:05 GMT 2020 - 8.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java
queue.enqueue(incrementingEvent(counters, listener, 2)); queue.enqueue(incrementingEvent(counters, listener, 3)); queue.enqueue(incrementingEvent(counters, listener, 4)); queue.enqueue(countDownEvent(latch)); assertEquals(0, counters.size()); queue.dispatch(); latch.await(); assertEquals(multiset(listener, 4), counters); } finally {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 8.2K bytes - Viewed (0) -
build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/docbook/ClassDocBuilder.java
private final GenerationListener listener = new DefaultGenerationListener(); public ClassDocBuilder(DslDocModel model, JavadocConverter javadocConverter) { commentBuilder = new ClassDocCommentBuilder(javadocConverter, listener); propertiesBuilder = new ClassDocPropertiesBuilder(javadocConverter, listener); methodsBuilder = new ClassDocMethodsBuilder(javadocConverter, listener);
Java - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Wed Dec 09 08:14:05 GMT 2020 - 2K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/lifecycle/internal/CompoundProjectExecutionListener.java
for (ProjectExecutionListener listener : listeners) { listener.beforeProjectExecution(event); } } @Override public void beforeProjectLifecycleExecution(ProjectExecutionEvent event) throws LifecycleExecutionException { for (ProjectExecutionListener listener : listeners) { listener.beforeProjectLifecycleExecution(event); } }
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Wed Jan 10 12:55:54 GMT 2024 - 2.3K bytes - Viewed (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/EventSources.kt
return EventSource.Factory { request, listener -> val actualRequest = if (request.header("Accept") == null) { request.newBuilder().addHeader("Accept", "text/event-stream").build() } else { request } RealEventSource(actualRequest, listener).apply { connect(callFactory) } } } @JvmStatic
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:18:15 GMT 2024 - 1.6K bytes - Viewed (1) -
maven-core/src/main/java/org/apache/maven/lifecycle/internal/DefaultExecutionEventCatapult.java
listener.sessionStarted(event); break; case SessionEnded: listener.sessionEnded(event); break; case ProjectSkipped: listener.projectSkipped(event); break; case ProjectStarted: listener.projectStarted(event); break;
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Wed Jan 10 12:55:54 GMT 2024 - 4.1K bytes - Viewed (0) -
maven-core/src/test/java/org/apache/maven/lifecycle/DelegatingMojoExecutionListener.java
for (MojoExecutionListener listener : listeners) { listener.afterExecutionFailure(event); } } public void addMojoExecutionListener(MojoExecutionListener listener) { this.listeners.add(listener); } public void removeMojoExecutionListener(MojoExecutionListener listener) { this.listeners.remove(listener); }
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Mon Dec 26 15:12:32 GMT 2022 - 2.2K bytes - Viewed (0) -
okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceHttpTest.kt
).setHeader("content-type", "text/event-stream") .build(), ) val source = newEventSource() assertThat(source.request().url.encodedPath).isEqualTo("/") listener.assertOpen() listener.assertEvent(null, null, "hey") listener.assertClose() } @RetryingTest(5) fun cancelInEventShortCircuits() { server.enqueue( MockResponse.Builder() .body( """
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Jan 14 10:20:09 GMT 2024 - 6.6K bytes - Viewed (0)