Function SplitAnnexB

common/frame.go:16–22

(frame T, process func(T), delimiter []byte)

)

func SplitAnnexB[T ~[]byte](frame T, process func(T), delimiter []byte) {
	for after := frame; len(frame) > 0; frame = after {
		if frame, after, _ = bytes.Cut(frame, delimiter); len(frame) > 0 {
			process(frame)
		}
	}
}

const rwmutexMaxReaders = 1 << 30