Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 12 of 12 for onRequest (0.09 sec)

  1. internal/grid/muxclient.go

    func (m *muxClient) roundtrip(h HandlerID, req []byte) ([]byte, error) {
    	if m.init {
    		return nil, errors.New("mux client already used")
    	}
    	m.init = true
    	m.singleResp = true
    	msg := message{
    		Op:         OpRequest,
    		MuxID:      m.MuxID,
    		Handler:    h,
    		Flags:      m.BaseFlags | FlagEOF,
    		Payload:    req,
    		DeadlineMS: uint32(m.deadline.Milliseconds()),
    	}
    	if m.subroute != nil {
    		msg.Flags |= FlagSubroute
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  2. internal/grid/connection.go

    		c.handleDisconnectServerMux(m)
    	case OpDisconnectClientMux:
    		c.handleDisconnectClientMux(m)
    	case OpPing:
    		c.handlePing(ctx, m)
    	case OpPong:
    		c.handlePong(ctx, m)
    	case OpRequest:
    		c.handleRequest(ctx, m, subID)
    	case OpAckMux:
    		c.handleAckMux(ctx, m)
    	case OpConnectMux:
    		c.handleConnectMux(ctx, m, subID)
    	case OpMuxConnectError:
    		c.handleConnectMuxError(ctx, m)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
Back to top