(bufSize int, timeout time.Duration)
| 42 | } |
| 43 | |
| 44 | func MakeQuickReorderQueue[T any](bufSize int, timeout time.Duration) *QuickReorderQueue[T] { |
| 45 | return &QuickReorderQueue[T]{ |
| 46 | sessionOrder: make(map[string]int64), |
| 47 | nextSeqNum: 1, |
| 48 | outCh: make(chan T, bufSize), |
| 49 | timeout: timeout, |
| 50 | } |
| 51 | } |
| 52 | |
| 53 | func (q *QuickReorderQueue[T]) C() <-chan T { |
| 54 | return q.outCh |