- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for newPayload (0.12 sec)
-
internal/grid/handlers.go
} else { s.InCapacity = 0 } s.respPool.New = func() interface{} { 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] {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 27.1K bytes - Viewed (0) -
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
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 9.4K bytes - Viewed (0) -
src/cmd/link/internal/loader/loader.go
panic("too many symbols") } if l.extStart == 0 { l.extStart = i } l.growValues(int(i) + 1) l.growOuter(int(i) + 1) l.growAttrBitmaps(int(i) + 1) pi := l.newPayload(name, ver) l.objSyms = append(l.objSyms, objSym{l.extReader.objidx, uint32(pi)}) l.extReader.syms = append(l.extReader.syms, i) return i }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 20:26:10 UTC 2024 - 81.5K bytes - Viewed (0)