Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for subStreams (0.07 sec)

  1. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 27.7K bytes
    - Viewed (0)
  2. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Nov 12 20:41:41 UTC 2024
    - 10.8K 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 46.9K bytes
    - Viewed (0)
Back to top