Function NewTask

pkg/queue/task.go:27–37

(ctx context.Context, id string, title string, data T)

}

func NewTask[T any](ctx context.Context, id string, title string, data T) *Task[T] {
	cancelCtx, cancel := context.WithCancel(ctx)
	return &Task[T]{
		ID:      id,
		Title:   title,
		Data:    data,
		ctx:     cancelCtx,
		cancel:  cancel,
		created: time.Now(),
	}
}

func (t *Task[T]) Cancelled() bool {
	select {