Commit 9a397e07 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 27b65c08
...@@ -557,6 +557,7 @@ func (root *Root) zwatcher(ctx context.Context) (err error) { ...@@ -557,6 +557,7 @@ func (root *Root) zwatcher(ctx context.Context) (err error) {
traceWatch("cancel") traceWatch("cancel")
return ctx.Err() return ctx.Err()
// TODO handle errors from ZODB watch stream
case zevent, ok = <-zwatchq: case zevent, ok = <-zwatchq:
if !ok { if !ok {
traceWatch("zwatchq closed") traceWatch("zwatchq closed")
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment