Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 3 of 3 for subStreams (0.05 seconds)

  1. internal/grid/connection.go

    		return nil, ErrUnknownHandler
    	}
    	if c.State() != StateConnected {
    		return nil, ErrDisconnected
    	}
    	handler := c.handlers.subStreams[makeZeroSubHandlerID(h)]
    	if handler == nil {
    		if debugPrint {
    			fmt.Println("want", makeZeroSubHandlerID(h), c.route, "got", c.handlers.subStreams)
    		}
    		return nil, ErrUnknownHandler
    	}
    
    	var requests chan []byte
    	var responses chan Response
    	if handler.InCapacity > 0 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 46.9K bytes
    - Click Count (0)
  2. architecture/standards/0001-use-architectural-decision-records.md

    # ADR-0001 - Use Architectural Decision Records
    
    ## Status
    
    - ACCEPTED on 2023-12-01
    
    ## Context
    
    In a distributed team with many subteams, the best solution to communicate decisions is to use a format accessible by everyone in charge of development.
    
    We use *Specification* and *Discovery* documents stored in Google Drive, but they present some downsides:
    
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Thu Mar 05 12:39:41 GMT 2026
    - 2.9K bytes
    - Click Count (0)
  3. src/main/java/org/codelibs/fess/helper/ViewHelper.java

                    return;
                }
                final FacetQueryView facetQueryView = new FacetQueryView();
                facetQueryView.setTitle(values[0]);
                split(values[1], "\t").of(subStream -> subStream.map(String::trim).filter(StringUtil::isNotEmpty).forEach(v -> {
                    final String[] facet = StringUtils.split(v, "=", 2);
                    if (facet.length == 2) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 52.6K bytes
    - Click Count (0)
Back to Top