Method DrainTx

internal/session/session.go:269–272

DrainTx removes pending tx bytes and returns them as a sequence of frames, each capped at maxPayload bytes. Emits a SYN frame first if needed, and a trailing FIN frame if RequestClose was called and the FIN hasn't been sent yet.

(maxPayload int)

// each capped at maxPayload bytes. Emits a SYN frame first if needed, and a
// trailing FIN frame if RequestClose was called and the FIN hasn't been sent yet.
func (s *Session) DrainTx(maxPayload int) []*frame.Frame {
	frames, _ := s.drainTx(maxPayload, 0, false)
	return frames
}

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