RingBuffer

ringbuffer.go

package main

type RingBuffer[T any] struct {
	inputChannel  <-chan T
	outputChannel chan T
}

func NewRingBuffer[T any](inputChannel <-chan T, outputChannel chan T) *RingBuffer[T] {
	return &RingBuffer[T]{inputChannel, outputChannel}
}

func (r *RingBuffer[T]) Run() {
	for v := range r.inputChannel {
		select {
		case r.outputChannel <- v:
		default:
			<-r.outputChannel
			r.outputChannel <- v
		}
	}
	close(r.outputChannel)
}

ringbuffer_test.go

func main() {
    in := make(chan int)
    out := make(chan int, 5)
    rb := NewRingBuffer(in, out)
    go rb.Run()

    for i := 0; i < 10; i++ {
        in <- i
    }

    close(in)

    for res := range out {
        fmt.Println(res)
    }
}

Generics Rignbuffer

original from A channel-based ring buffer in Go

Go Playground