store: replace go errors with verrors
Though this change is not very small, it is just a couple of
rules applied across the code.
Change-Id: I88e0088bb40e5218e24fbe093b2f726342bc607a
diff --git a/services/syncbase/store/memstore/stream.go b/services/syncbase/store/memstore/stream.go
index f60e27e..09ccfe3 100644
--- a/services/syncbase/store/memstore/stream.go
+++ b/services/syncbase/store/memstore/stream.go
@@ -5,11 +5,11 @@
package memstore
import (
- "errors"
"sort"
"sync"
"v.io/syncbase/x/ref/services/syncbase/store"
+ "v.io/v23/verror"
)
type stream struct {
@@ -82,12 +82,15 @@
func (s *stream) Err() error {
s.mu.Lock()
defer s.mu.Unlock()
- return s.err
+ return store.WrapError(s.err)
}
// Cancel implements the store.Stream interface.
func (s *stream) Cancel() {
s.mu.Lock()
defer s.mu.Unlock()
- s.err = errors.New("canceled stream")
+ if s.err != nil {
+ return
+ }
+ s.err = verror.New(verror.ErrCanceled, nil, "canceled stream")
}
