Commit39526e6

committed

update noop impl.

1 parentaed7c30 commit39526e6Copy full SHA for 39526e6

File tree

-3

lines changed

-3

lines changed

Lines changed: 3 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -5,7 +5,6 @@ import (`
`5`	`5`	`"sync"`
`6`	`6`
`7`	`7`	`"github.com/fsnotify/fsnotify"`
`8`		`-"golang.org/x/xerrors"`
`9`	`8`	`)`
`10`	`9`
`11`	`10`	`// NewNoop creates a new watcher that does nothing.`
`@@ -27,20 +26,21 @@ func (*noopWatcher) Remove(string) error {`
`27`	`26`	`returnnil`
`28`	`27`	`}`
`29`	`28`
	`29`	`+// Next blocks until the context is canceled or the watcher is closed.`
`30`	`30`	`func (nnoopWatcher)Next(ctx context.Context) (fsnotify.Event,error) {`
`31`	`31`	`select {`
`32`	`32`	`case<-ctx.Done():`
`33`	`33`	`returnnil,ctx.Err()`
`34`	`34`	`case<-n.done:`
`35`		`-returnnil,xerrors.New("watcher closed")`
	`35`	`+returnnil,ErrWatcherClosed`
`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`		`-returnnil`
	`43`	`+returnErrWatcherClosed`
`44`	`44`	`}`
`45`	`45`	`n.closed=true`
`46`	`46`	`close(n.done)`

Comments

(0)