Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 81 - 90 of 150 for channel2 (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. android/guava/src/com/google/common/eventbus/EventBus.java

     * href="https://kotlinlang.org/docs/coroutines-guide.html">Kotlin coroutines</a>, including <a
     * href="https://kotlinlang.org/docs/flow.html">Flow</a> and <a
     * href="https://kotlinlang.org/docs/channels.html">Channels</a>. Yet other usages are better served
     * by individual libraries that provide specialized support for particular use cases.
     *
     * <p>Disadvantages of EventBus include:
     *
     * <ul>
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 12.7K bytes
    - Click Count (0)
  2. src/main/java/jcifs/internal/smb2/session/Smb2SessionSetupRequest.java

            dst[dstIndex + 3] = (byte) this.securityMode;
            dstIndex += 4;
    
            SMBUtil.writeInt4(this.capabilities, dst, dstIndex);
            dstIndex += 4;
            SMBUtil.writeInt4(0, dst, dstIndex); // Channel
            dstIndex += 4;
    
            final int offsetOffset = dstIndex;
            dstIndex += 2;
            SMBUtil.writeInt2(this.token != null ? this.token.length : 0, dst, dstIndex);
            dstIndex += 2;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 4.8K bytes
    - Click Count (0)
  3. internal/event/target/webhook.go

    	if err := target.init(); err != nil {
    		return err
    	}
    
    	eventData, eErr := target.store.Get(key)
    	if eErr != nil {
    		// The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
    		// Such events will not exist and would've been already been sent successfully.
    		if os.IsNotExist(eErr) {
    			return nil
    		}
    		return eErr
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Sep 06 23:06:30 GMT 2024
    - 8.8K bytes
    - Click Count (0)
  4. docs/en/docs/deployment/manually.md

    * [Hypercorn](https://hypercorn.readthedocs.io/): an ASGI server compatible with HTTP/2 and Trio among other features.
    * [Daphne](https://github.com/django/daphne): the ASGI server built for Django Channels.
    * [Granian](https://github.com/emmett-framework/granian): A Rust HTTP server for Python applications.
    * [NGINX Unit](https://unit.nginx.org/howto/fastapi/): NGINX Unit is a lightweight and versatile web application runtime.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 6.7K bytes
    - Click Count (0)
  5. docs/es/docs/deployment/manually.md

    * [Hypercorn](https://hypercorn.readthedocs.io/): un servidor ASGI compatible con HTTP/2 y Trio entre otras funcionalidades.
    * [Daphne](https://github.com/django/daphne): el servidor ASGI construido para Django Channels.
    * [Granian](https://github.com/emmett-framework/granian): Un servidor HTTP Rust para aplicaciones en Python.
    * [NGINX Unit](https://unit.nginx.org/howto/fastapi/): NGINX Unit es un runtime para aplicaciones web ligero y versátil.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:15:55 GMT 2026
    - 7K bytes
    - Click Count (0)
  6. docs/uk/docs/deployment/manually.md

    * [Hypercorn](https://hypercorn.readthedocs.io/): ASGI-сервер, сумісний з HTTP/2 і Trio, серед інших можливостей.
    * [Daphne](https://github.com/django/daphne): ASGI-сервер, створений для Django Channels.
    * [Granian](https://github.com/emmett-framework/granian): Rust HTTP-сервер для Python-застосунків.
    * [NGINX Unit](https://unit.nginx.org/howto/fastapi/): NGINX Unit - легке й універсальне середовище виконання вебзастосунків.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:27:41 GMT 2026
    - 9.1K bytes
    - Click Count (0)
  7. internal/event/target/mqtt.go

    	_, err := target.isActive()
    	if err != nil {
    		return err
    	}
    
    	eventData, err := target.store.Get(key)
    	if err != nil {
    		// The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
    		// Such events will not exist and wouldve been already been sent successfully.
    		if os.IsNotExist(err) {
    			return nil
    		}
    		return err
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Sep 06 23:06:30 GMT 2024
    - 8.2K bytes
    - Click Count (0)
  8. docs/zh-hant/docs/deployment/manually.md

    有數個替代方案,包括:
    
    * [Uvicorn](https://www.uvicorn.dev/):高效能 ASGI 伺服器。
    * [Hypercorn](https://hypercorn.readthedocs.io/):支援 HTTP/2 與 Trio 等功能的 ASGI 伺服器。
    * [Daphne](https://github.com/django/daphne):為 Django Channels 打造的 ASGI 伺服器。
    * [Granian](https://github.com/emmett-framework/granian):針對 Python 應用的 Rust HTTP 伺服器。
    * [NGINX Unit](https://unit.nginx.org/howto/fastapi/):NGINX Unit 是輕量且多功能的網頁應用執行環境。
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Mar 20 17:05:38 GMT 2026
    - 6.2K bytes
    - Click Count (0)
  9. cmd/metacache-server-pool.go

    			entries.listID = o.ID
    		}
    	}
    	if !truncated {
    		return entries, io.EOF
    	}
    	return entries, nil
    }
    
    // listMerged will list across all sets and return a merged results stream.
    // The result channel is closed when no more results are expected.
    func (z *erasureServerPools) listMerged(ctx context.Context, o listPathOptions, results chan<- metaCacheEntry) error {
    	var mu sync.Mutex
    	var wg sync.WaitGroup
    	var errs []error
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 12.9K bytes
    - Click Count (0)
  10. internal/event/target/nsq.go

    	}
    
    	_, err := target.isActive()
    	if err != nil {
    		return err
    	}
    
    	eventData, eErr := target.store.Get(key)
    	if eErr != nil {
    		// The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
    		// Such events will not exist and wouldve been already been sent successfully.
    		if os.IsNotExist(eErr) {
    			return nil
    		}
    		return eErr
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 7.1K bytes
    - Click Count (0)
Back to Top