Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for subSingle (0.15 sec)

  1. internal/grid/manager.go

    	if m.handlers.hasSubhandler(subID) && !id.isTestHandler() {
    		return fmt.Errorf("handler %v, subroute:%v: %w", id.String(), s, ErrHandlerAlreadyExists)
    	}
    	m.handlers.subSingle[subID] = h
    	// Copy so clients can also pick it up for other subpaths.
    	m.handlers.subSingle[makeZeroSubHandlerID(id)] = h
    	return nil
    }
    
    /*
    // RegisterStateless will register a stateless handler that serves
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.5K bytes
    - Viewed (0)
  2. internal/grid/handlers.go

    	single    [handlerLast]SingleHandlerFn
    	stateless [handlerLast]*StatelessHandler
    	streams   [handlerLast]*StreamHandler
    
    	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)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 27.1K bytes
    - Viewed (0)
  3. internal/grid/connection.go

    		fmt.Println(m.MuxID, c.StringReverse(), "INCOMING")
    	}
    	// Singleshot message
    	var handler SingleHandlerFn
    	if subID == nil {
    		handler = c.handlers.single[m.Handler]
    	} else {
    		handler = c.handlers.subSingle[*subID]
    	}
    	if handler == nil {
    		gridLogIf(ctx, c.queueMsg(m, muxConnectError{Error: "Invalid Handler for type"}))
    		return
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
Back to top