errors.go
 1package agent
 2
 3import (
 4	"context"
 5	"errors"
 6)
 7
 8var (
 9	ErrRequestCancelled = errors.New("request canceled by user")
10	ErrStreamTimeout    = errors.New("stream chunk timeout")
11	ErrSessionBusy      = errors.New("session is currently processing another request")
12)
13
14func isCancelledErr(err error) bool {
15	return errors.Is(err, context.Canceled) || errors.Is(err, ErrRequestCancelled)
16}