Searched defs:inFlow (Results 1 – 1 of 1) sorted by relevance
146 type inFlow struct { struct147 mu sync.Mutex149 limit uint32152 pendingData uint32155 pendingUpdate uint32158 delta uint32163 func (f *inFlow) newLimit(n uint32) uint32 {171 func (f *inFlow) maybeAdjust(n uint32) uint32 {204 func (f *inFlow) onData(n uint32) error {219 func (f *inFlow) onRead(n uint32) uint32 {