Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for RequestStateless (0.2 sec)

  1. internal/grid/muxclient.go

    		dst = binary.LittleEndian.AppendUint32(dst, uint32(h))
    	}
    	return m.parent.send(m.ctx, dst)
    }
    
    // RequestStateless will send a single payload request and stream back results.
    // req may not be read/written to after calling.
    // TODO: Not implemented
    func (m *muxClient) RequestStateless(h HandlerID, req []byte, out chan<- Response) {
    	if m.init {
    		out <- Response{Err: errors.New("mux client already used")}
    	}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.2K bytes
    - Viewed (0)
  2. internal/grid/connection.go

    	client, err := c.newMuxClient(ctx)
    	if err != nil {
    		return err
    	}
    	defer c.outgoing.Delete(client.MuxID)
    	resp := make(chan Response, 10)
    	client.RequestStateless(h, req, resp)
    
    	for r := range resp {
    		if r.Err != nil {
    			return r.Err
    		}
    		if len(r.Msg) > 0 {
    			err := cb(r.Msg)
    			if err != nil {
    				if errors.Is(err, ErrDone) {
    					break
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
Back to top