Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for subStreams (0.29 sec)

  1. internal/grid/manager.go

    	}
    	subID := makeSubHandlerID(id, h.Subroute)
    	if m.handlers.hasSubhandler(subID) && !id.isTestHandler() {
    		return ErrHandlerAlreadyExists
    	}
    	m.handlers.subStreams[subID] = &h
    	// Copy so clients can also pick it up for other subpaths.
    	m.handlers.subStreams[makeZeroSubHandlerID(id)] = &h
    	return nil
    }
    
    // HostName returns the name of the local host.
    func (m *Manager) HostName() string {
    	return m.local
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  2. internal/grid/handlers.go

    	subSingle    map[subHandlerID]SingleHandlerFn
    	subStateless map[subHandlerID]*StatelessHandler
    	subStreams   map[subHandlerID]*StreamHandler
    }
    
    func (h *handlers) init() {
    	h.subSingle = make(map[subHandlerID]SingleHandlerFn)
    	h.subStateless = make(map[subHandlerID]*StatelessHandler)
    	h.subStreams = make(map[subHandlerID]*StreamHandler)
    }
    
    func (h *handlers) hasAny(id HandlerID) bool {
    	if !id.valid() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 27.7K bytes
    - Viewed (0)
  3. 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 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  4. architecture/standards/0001-use-architectural-decision-records.md

    # ADR-0001 - Use Architectural Decision Records
    
    ## Date
    
    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:
    
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Sat Mar 02 21:54:40 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  5. 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) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 40.2K bytes
    - Viewed (0)
Back to top