Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 51 - 56 of 56 for on_event (0.04 seconds)

  1. okhttp-sse/src/test/java/okhttp3/sse/internal/ServerSentEventIteratorTest.kt

        assertThat(callbacks).isEmpty()
      }
    
      private fun consumeEvents(source: String) {
        val callback: ServerSentEventReader.Callback =
          object : ServerSentEventReader.Callback {
            override fun onEvent(
              id: String?,
              type: String?,
              data: String,
            ) {
              callbacks.add(Event(id, type, data))
            }
    
            override fun onRetryChange(timeMs: Long) {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 6.4K bytes
    - Click Count (0)
  2. compat/maven-embedder/src/test/java/org/apache/maven/cli/MavenCliTest.java

            orderedEventSpyDispatcherMock
                    .verify(eventSpyDispatcherMock, times(1))
                    .onEvent(any(ToolchainsBuildingRequest.class));
            orderedEventSpyDispatcherMock
                    .verify(eventSpyDispatcherMock, times(1))
                    .onEvent(any(ToolchainsBuildingResult.class));
        }
    
        @Test
        void resumeFromSelectorIsSuggestedWithoutGroupId() {
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Sep 17 10:01:14 GMT 2025
    - 30.9K bytes
    - Click Count (0)
  3. compat/maven-embedder/src/main/java/org/apache/maven/cli/MavenCli.java

                cliRequest.request.setRepositoryCache(new DefaultRepositoryCache());
            }
    
            eventSpyDispatcher.onEvent(request);
    
            MavenExecutionResult result = maven.execute(request);
    
            eventSpyDispatcher.onEvent(result);
    
            eventSpyDispatcher.close();
    
            if (result.hasExceptions()) {
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Mon Oct 27 13:24:03 GMT 2025
    - 78.1K bytes
    - Click Count (0)
  4. .teamcity/src/main/kotlin/common/CommonExtensions.kt

            param("env.BUILD_BRANCH", "%teamcity.build.branch%")
        }
    
        vcs {
            root(AbsoluteId(VersionedSettingsBranch.fromDslContext().vcsRootId()))
            checkoutMode = CheckoutMode.ON_AGENT
            branchFilter = branchesFilterExcluding()
        }
    
        features {
            enablePullRequestFeature()
        }
    
        requirements {
            requiresOs(os)
            requiresArch(os, arch)
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Fri Mar 13 05:03:56 GMT 2026
    - 14.8K bytes
    - Click Count (0)
  5. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/LookupInvoker.java

                    .build();
    
            customizeSettingsRequest(context, settingsRequest);
            if (context.eventSpyDispatcher != null) {
                context.eventSpyDispatcher.onEvent(settingsRequest);
            }
    
            context.logger.debug("Reading installation settings from '" + installationSettingsFile + "'");
            context.logger.debug("Reading project settings from '" + projectSettingsFile + "'");
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Tue Oct 28 13:01:07 GMT 2025
    - 43.2K bytes
    - Click Count (0)
  6. impl/maven-core/src/main/java/org/apache/maven/ReactorReader.java

            ReactorReaderSpy(Lookup lookup) {
                this.lookup = lookup;
            }
    
            @Override
            public void init(Context context) throws Exception {}
    
            @Override
            public void onEvent(Object event) throws Exception {
                if (event instanceof ExecutionEvent executionEvent) {
                    ReactorReader reactorReader = lookup.lookup(ReactorReader.class);
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Mon Dec 15 11:20:38 GMT 2025
    - 24.4K bytes
    - Click Count (0)
Back to Top