loop

package

v0.15.2 Latest Latest Go to latest Published: Apr 23, 2025 License: Apache-2.0 Imports: 1 Imported by: 1

Details

This section is empty.

This section is empty.

This section is empty.

type HandlerFunc[T any] func(context.Context, T) error

type Loop[T any] struct {
	// contains filtered or unexported fields
}

func New[T any](opts Options[T]) *Loop[T]

func (l *Loop[T]) Enqueue(req T)

func (l *Loop[T]) Run(ctx context.Context) error

type Options[T any] struct {
	Handler    HandlerFunc[T]
	BufferSize *uint64
}