Commit0b16448

committed

s/ErrWatcherClosed/ErrClosed/g

1 parent5a96a55 commit0b16448Copy full SHA for 0b16448

File tree

-8

lines changed

-8

lines changed

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -152,7 +152,7 @@ func (api *API) start() {`
`152`	`152`	`for {`
`153`	`153`	`event,err:=api.watcher.Next(api.ctx)`
`154`	`154`	`iferr!=nil {`
`155`		`-iferrors.Is(err,watcher.ErrWatcherClosed) {`
	`155`	`+iferrors.Is(err,watcher.ErrClosed) {`
`156`	`156`	`api.logger.Debug(api.ctx,"watcher closed")`
`157`	`157`	`return`
`158`	`158`	`}`

Lines changed: 2 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -32,15 +32,15 @@ func (n noopWatcher) Next(ctx context.Context) (fsnotify.Event, error) {`
`32`	`32`	`case<-ctx.Done():`
`33`	`33`	`returnnil,ctx.Err()`
`34`	`34`	`case<-n.done:`
`35`		`-returnnil,ErrWatcherClosed`
	`35`	`+returnnil,ErrClosed`
`36`	`36`	`}`
`37`	`37`	`}`
`38`	`38`
`39`	`39`	`func (n*noopWatcher)Close()error {`
`40`	`40`	`n.mu.Lock()`
`41`	`41`	`defern.mu.Unlock()`
`42`	`42`	`ifn.closed {`
`43`		`-returnErrWatcherClosed`
	`43`	`+returnErrClosed`
`44`	`44`	`}`
`45`	`45`	`n.closed=true`
`46`	`46`	`close(n.done)`

Lines changed: 5 additions & 5 deletions

Original file line number	Diff line number	Diff line change
`@@ -15,7 +15,7 @@ import (`
`15`	`15`	`"golang.org/x/xerrors"`
`16`	`16`	`)`
`17`	`17`
`18`		`-varErrWatcherClosed=xerrors.New("watcher closed")`
	`18`	`+varErrClosed=xerrors.New("watcher closed")`
`19`	`19`
`20`	`20`	`// Watcher defines an interface for monitoring file system changes.`
`21`	`21`	`// Implementations track file modifications and provide an event stream`
`@@ -140,7 +140,7 @@ func (f fsnotifyWatcher) Next(ctx context.Context) (event fsnotify.Event, err`
`140`	`140`	`returnnil,ctx.Err()`
`141`	`141`	`caseevt,ok:=<-f.Events:`
`142`	`142`	`if!ok {`
`143`		`-returnnil,ErrWatcherClosed`
	`143`	`+returnnil,ErrClosed`
`144`	`144`	`}`
`145`	`145`
`146`	`146`	`// Get the absolute path to match against our watched files.`
`@@ -160,11 +160,11 @@ func (f fsnotifyWatcher) Next(ctx context.Context) (event fsnotify.Event, err`
`160`	`160`
`161`	`161`	`caseerr,ok:=<-f.Errors:`
`162`	`162`	`if!ok {`
`163`		`-returnnil,ErrWatcherClosed`
	`163`	`+returnnil,ErrClosed`
`164`	`164`	`}`
`165`	`165`	`returnnil,xerrors.Errorf("watcher error: %w",err)`
`166`	`166`	`case<-f.done:`
`167`		`-returnnil,ErrWatcherClosed`
	`167`	`+returnnil,ErrClosed`
`168`	`168`	`}`
`169`	`169`	`}`
`170`	`170`	`}`
`@@ -178,7 +178,7 @@ func (f *fsnotifyWatcher) Close() (err error) {`
`178`	`178`	`f.mu.Unlock()`
`179`	`179`
`180`	`180`	`ifclosed {`
`181`		`-returnErrWatcherClosed`
	`181`	`+returnErrClosed`
`182`	`182`	`}`
`183`	`183`
`184`	`184`	`close(f.done)`

Comments

(0)