Method DrainTxLimited

internal/session/session.go:276–279

DrainTxLimited is like DrainTx but emits at most maxFrames frames in one call (0 means unlimited). Remaining bytes stay queued for later polls.

(maxPayload, maxFrames int)

// DrainTxLimited is like DrainTx but emits at most maxFrames frames in one
// call (0 means unlimited). Remaining bytes stay queued for later polls.
func (s *Session) DrainTxLimited(maxPayload, maxFrames int) []*frame.Frame {
	frames, _ := s.drainTx(maxPayload, maxFrames, false)
	return frames
}

// DrainTxLimitedTxn is like DrainTxLimited but also returns a snapshot of the
// pre-drain state. If the caller cannot transmit the returned frames (HTTP