Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 2 of 2 for NewPayload (0.04 seconds)

  1. internal/grid/handlers.go

    		s.InCapacity = 0
    	}
    	s.respPool.New = func() Resp {
    		return newResp()
    	}
    	s.newPayload = newPayload
    	s.WithPayload = newPayload != nil
    	return s
    }
    
    // WithSharedResponse indicates it is unsafe to reuse the response.
    // Typically this is used when the response sharing part of its data structure.
    func (h *StreamTypeHandler[Payload, Req, Resp]) WithSharedResponse() *StreamTypeHandler[Payload, Req, Resp] {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 27.7K bytes
    - Click Count (0)
  2. internal/grid/README.md

        // Due to current generics limitations, a constructor of the empty type must be provided.
        instance := grid.NewStream[*Payload, *Req, *Resp](h, newPayload, newReq, newResp)
    
        // Tweakable options
        instance.WithPayload = true // default true when newPayload != nil
        instance.OutCapacity = 1    // default
        instance.InCapacity = 1     // default true when newReq != nil
    
        // Register the handler on the manager
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Oct 10 18:57:03 GMT 2025
    - 9.4K bytes
    - Click Count (0)
Back to Top