type writeQuota …
func newWriteQuota(sz int32, done <-chan struct{ … }
func (w *writeQuota) get(sz int32) error { … }
func (w *writeQuota) realReplenish(n int) { … }
type trInFlow …
func (f *trInFlow) newLimit(n uint32) uint32 { … }
func (f *trInFlow) onData(n uint32) uint32 { … }
func (f *trInFlow) reset() uint32 { … }
func (f *trInFlow) updateEffectiveWindowSize() { … }
func (f *trInFlow) getSize() uint32 { … }
type inFlow …
func (f *inFlow) newLimit(n uint32) { … }
func (f *inFlow) maybeAdjust(n uint32) uint32 { … }
func (f *inFlow) onData(n uint32) error { … }
func (f *inFlow) onRead(n uint32) uint32 { … }