Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 307 for listener (0.09 sec)

  1. okhttp/src/test/java/okhttp3/ServerTruncatesRequestTest.kt

      @RegisterExtension
      @JvmField
      var clientTestRule = OkHttpClientTestRule()
    
      private val listener = RecordingEventListener()
      private val handshakeCertificates = platform.localhostHandshakeCertificates()
    
      private var client =
        clientTestRule.newClientBuilder()
          .eventListenerFactory(clientTestRule.wrap(listener))
          .build()
    
      private lateinit var server: MockWebServer
    
      @BeforeEach
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  2. api/maven-api-core/src/main/java/org/apache/maven/api/Event.java

    import org.apache.maven.api.annotations.Experimental;
    import org.apache.maven.api.annotations.Nonnull;
    
    /**
     * Event sent by maven during various phases of the build process.
     * Such events can be listened to using {@link Listener}s objects
     * registered in the {@link Session}.
     *
     * @since 4.0.0
     */
    @Experimental
    public interface Event {
    
        /**
         * Gets the type of the event.
         *
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Thu Mar 23 05:29:39 UTC 2023
    - 2.1K bytes
    - Viewed (0)
  3. internal/http/check_port_linux.go

    		},
    	}
    
    	ctx, cancel := context.WithTimeout(context.Background(), time.Second)
    	defer cancel()
    
    	l, err := lc.Listen(ctx, "tcp", net.JoinHostPort(host, port))
    	if err != nil {
    		return err
    	}
    
    	// As we are able to listen on this network, the port is not in use.
    	// Close the listener and continue check other networks.
    	return l.Close()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 03 21:12:25 UTC 2023
    - 1.9K bytes
    - Viewed (0)
  4. internal/http/check_port_others.go

    	}
    
    	// As we are able to listen on this network, the port is not in use.
    	// Close the listener and continue check other networks.
    	return l.Close()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 03 21:12:25 UTC 2023
    - 1.5K bytes
    - Viewed (0)
  5. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvn/DefaultMavenInvoker.java

            ExecutionListener listener = new ExecutionEventLogger(context.invokerRequest.messageBuilderFactory());
            if (context.eventSpyDispatcher != null) {
                listener = context.eventSpyDispatcher.chainListener(listener);
            }
            listener = new LoggingExecutionListener(listener, determineBuildEventListener(context));
            return listener;
        }
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 29.8K bytes
    - Viewed (0)
  6. okhttp-logging-interceptor/src/main/kotlin/okhttp3/logging/LoggingEventListener.kt

    /**
     * An OkHttp EventListener, which logs call events. Can be applied as an
     * [event listener factory][OkHttpClient.eventListenerFactory].
     *
     * The format of the logs created by this class should not be considered stable and may change
     * slightly between releases. If you need a stable logging format, use your own event listener.
     */
    class LoggingEventListener private constructor(
      private val logger: HttpLoggingInterceptor.Logger,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 01 11:07:32 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  7. cni/pkg/nodeagent/cni-watcher.go

    			// If the cniListener exits, at least we should record an error log
    			log.Errorf("CNI listener server exiting unexpectedly: %v", err)
    		}
    	}()
    
    	context.AfterFunc(s.ctx, func() {
    		if err := s.cniListenServer.Close(); err != nil {
    			log.Errorf("CNI listen server terminated with error: %v", err)
    		} else {
    			log.Debug("CNI listen server terminated")
    		}
    	})
    	return nil
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Jul 02 18:48:50 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  8. compat/maven-model-builder/src/main/java/org/apache/maven/model/building/ModelBuildingRequest.java

        /**
         * Gets the model building listener to notify during the build process.
         *
         * @return The model building listener to notify or {@code null} if none.
         */
        ModelBuildingListener getModelBuildingListener();
    
        /**
         * Sets the model building listener to notify during the build process.
         *
         * @param modelBuildingListener The model building listener to notify, may be {@code null}.
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 14.9K bytes
    - Viewed (0)
  9. .github/hub_scripts/pr_ci.sh

    # See the License for the specific language governing permissions and
    # limitations under the License.
    #
    
    #
    # Simple shell script for launching CI jobs using the @bot-gradle GitHub comment listener.
    # Uses the [hub](https://hub.github.com/) CLI command to issue API requests to GitHub.
    # This script must be executed from the branch associated with the PR to issue the command on.
    #
    
    PR_NUMBER=$(hub pr show -f '%I')
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Fri Jan 22 15:25:21 UTC 2021
    - 1K bytes
    - Viewed (0)
  10. mockwebserver/src/test/java/mockwebserver3/internal/http2/Http2Server.kt

    import okio.source
    
    /** A basic HTTP/2 server that serves the contents of a local directory.  */
    class Http2Server(
      private val baseDirectory: File,
      private val sslSocketFactory: SSLSocketFactory,
    ) : Http2Connection.Listener() {
      private fun run() {
        val serverSocket = ServerSocket(8888)
        serverSocket.reuseAddress = true
        while (true) {
          var socket: Socket? = null
          try {
            socket = serverSocket.accept()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 6.1K bytes
    - Viewed (0)
Back to top