Search Options

Results per page
Sort
Preferred Languages
Advance

Results 191 - 200 of 272 for eventbus (0.26 sec)

  1. docs/pt/docs/features.md

    * Suporte a **WebSocket**.
    * Suporte a **GraphQL**.
    * Tarefas em processo _background_.
    * Eventos na inicialização e encerramento.
    * Cliente de testes construído sobre HTTPX.
    * Respostas em **CORS**, GZip, Static Files, Streaming.
    * Suporte a **Session e Cookie**.
    * 100% de cobertura de testes.
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  2. compat/maven-embedder/src/main/java/org/apache/maven/cli/event/ExecutionEventLogger.java

    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    import static org.apache.maven.cli.CLIReportingUtils.formatDuration;
    import static org.apache.maven.cli.CLIReportingUtils.formatTimestamp;
    
    /**
     * Logs execution events to logger, eventually user-supplied.
     *
     */
    public class ExecutionEventLogger extends AbstractExecutionListener {
        private static final int MAX_LOG_PREFIX_SIZE = 8; // "[ERROR] "
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  3. internal/logger/target/kafka/kafka.go

    	// Sending a value on logCh must hold read lock on logChMu (to avoid closing)
    	logCh   chan interface{}
    	logChMu sync.RWMutex
    
    	// store to persist and replay the logs to the target
    	// to avoid missing events when the target is down.
    	store          store.Store[interface{}]
    	storeCtxCancel context.CancelFunc
    
    	initKafkaOnce      once.Init
    	initQueueStoreOnce once.Init
    
    	client   sarama.Client
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  4. docs/es/docs/features.md

    * Soporte para **WebSocket**.
    * <abbr title="En español: tareas que se ejecutan en el fondo, sin frenar requests, en el mismo proceso. En ingles: In-process background tasks">Tareas en background</abbr>.
    * Eventos de startup y shutdown.
    * Cliente de pruebas construido con HTTPX.
    * **CORS**, GZip, Static Files, Streaming responses.
    * Soporte para **Session and Cookie**.
    * Cobertura de pruebas al 100%.
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Mon Aug 19 18:15:21 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

      private val writerQueue = taskRunner.newQueue()
    
      /** Ensures push promise callbacks events are sent in order per stream. */
      private val pushQueue = taskRunner.newQueue()
    
      /** Notifies the listener of settings changes. */
      private val settingsListenerQueue = taskRunner.newQueue()
    
      /** User code to run in response to push promise events. */
      private val pushObserver: PushObserver = builder.pushObserver
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 32.6K bytes
    - Viewed (0)
  6. docs/en/docs/features.md

    * **WebSocket** support.
    * In-process background tasks.
    * Startup and shutdown events.
    * Test client built on HTTPX.
    * **CORS**, GZip, Static Files, Streaming responses.
    * **Session and Cookie** support.
    * 100% test coverage.
    * 100% type annotated codebase.
    
    ## Pydantic features
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Aug 15 23:30:12 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  7. docs/fa/docs/features.md

    * پشتیبانی از **WebSocket**.
    * <abbr title="In-process background tasks">تسک های درجریان در پس زمینه</abbr>.
    * <abbr title="Startup and shutdown events">رویداد های راه اندازی و متوفق شدن<abbr>.
    * تست کلاینت ساخته شده به روی HTTPX.
    * **CORS**, GZip, فایل های استاتیک, <abbr title="Streaming responses">پاسخ های جریانی</abbr>.
    * پشتیبانی از **نشست ها و کوکی ها**.
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 15K bytes
    - Viewed (0)
  8. cmd/globals.go

    	// global Trace system to send HTTP request/response
    	// and Storage/OS calls info to registered listeners.
    	globalTrace = pubsub.New[madmin.TraceInfo, madmin.TraceType](8)
    
    	// global Listen system to send S3 API events to registered listeners
    	globalHTTPListen = pubsub.New[event.Event, pubsub.Mask](0)
    
    	// global console system to send console logs to
    	// registered listeners
    	globalConsoleSys *HTTPConsoleLoggerSys
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  9. docs/nl/docs/features.md

    * **WebSocket** ondersteuning.
    * Taken in de achtergrond tijdens het proces.
    * Opstart- en afsluit events.
    * Test client gebouwd op HTTPX.
    * **CORS**, GZip, Statische bestanden, Streaming reacties.
    * **Sessie en Cookie** ondersteuning.
    * 100% van de code is getest.
    * 100% type geannoteerde codebase.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Sep 03 13:50:38 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  10. cmd/test-utils_test.go

    }
    
    // return URL for listen bucket notification.
    func getListenNotificationURL(endPoint, bucketName string, prefixes, suffixes, events []string) string {
    	queryValue := url.Values{}
    
    	queryValue["prefix"] = prefixes
    	queryValue["suffix"] = suffixes
    	queryValue["events"] = events
    	return makeTestTargetURL(endPoint, bucketName, "", queryValue)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
Back to top