mirror of
https://gitlab.com/pulsechaincom/prysm-pulse.git
synced 2025-01-08 18:51:19 +00:00
da20785685
Former-commit-id: 23f542f43b4b493e38f5aa4c29788ed93a63b43b [formerly 71b23a6a28eb045fcfeab6329de69f1e5455486b] Former-commit-id: d12b3a6decc876f010a71f98e11df7387c1aaf2a
23 lines
538 B
Go
23 lines
538 B
Go
// Copyright (c) 2014-2015 The Notify Authors. All rights reserved.
|
|
// Use of this source code is governed by the MIT license that can be
|
|
// found in the LICENSE file.
|
|
|
|
package notify
|
|
|
|
const buffer = 128
|
|
|
|
type tree interface {
|
|
Watch(string, chan<- EventInfo, ...Event) error
|
|
Stop(chan<- EventInfo)
|
|
Close() error
|
|
}
|
|
|
|
func newTree() tree {
|
|
c := make(chan EventInfo, buffer)
|
|
w := newWatcher(c)
|
|
if rw, ok := w.(recursiveWatcher); ok {
|
|
return newRecursiveTree(rw, c)
|
|
}
|
|
return newNonrecursiveTree(w, c, make(chan EventInfo, buffer))
|
|
}
|