Commit 68a0b2e2 authored by zhengyaoqiu's avatar zhengyaoqiu

feat(colorway): 空指针修复

parent 5abdeeab
...@@ -31,7 +31,7 @@ type Base[T any] struct { ...@@ -31,7 +31,7 @@ type Base[T any] struct {
} }
func NewBase[T any](baseModel model.Model[T], changeStream ChangeStream[T]) *Base[T] { func NewBase[T any](baseModel model.Model[T], changeStream ChangeStream[T]) *Base[T] {
return &Base[T]{baseModel: baseModel, changeStream: changeStream} return &Base[T]{baseModel: baseModel, changeStream: changeStream, rwMutex: &sync.RWMutex{}}
} }
func (receiver *Base[T]) StartCache(ctx context.Context) error { func (receiver *Base[T]) StartCache(ctx context.Context) error {
......
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