fix review comments

Signed-off-by: jyjiangkai <[email protected]>

Author: hwjiangkai

Diff for: client/client.go

@@ -89,11 +89,8 @@ func (c *client) Eventbus(ctx context.Context, opts ...api.EventbusOption) (api.
 }
 
 func (c *client) Disconnect(ctx context.Context) {
-	c.mu.Lock()
-	defer c.mu.Unlock()
 	c.cache.Range(func(key, value interface{}) bool {
 		value.(api.Eventbus).Close(ctx)
-		c.cache.Delete(key)
 		return true
 	})
 }

Diff for: client/examples/eventbus/append/main.go

@@ -41,7 +41,7 @@ func main() {
 	if err != nil {
 		panic("invalid id")
 	}
-	bus, err := c.Eventbus(ctx, api.WithName("quick-start"), api.WithID(eventbusID.Uint64()))
+	bus, err := c.Eventbus(ctx, api.WithID(eventbusID.Uint64()))
 	if err != nil {
 		panic(err.Error())
 	}

Diff for: client/pkg/eventbus/eventbus.go

@@ -512,6 +512,9 @@ func (w *busWriter) pickWritableLog(ctx context.Context, opts *api.WriteOptions)
 	if err != nil {
 		return nil, err
 	}
+	if lw == nil {
+		return nil, errors.ErrResourceCanNotOp.WithMessage("can not pick writable log")
+	}
 
 	return lw.Writer(), nil
 }
@@ -588,6 +591,9 @@ func (r *busReader) pickReadableLog(ctx context.Context, opts *api.ReadOptions)
 	if err != nil {
 		return nil, err
 	}
+	if lr == nil {
+		return nil, errors.ErrResourceCanNotOp.WithMessage("can not pick readable log")
+	}
 
 	return lr.Reader(eventlog.ReaderConfig{PollingTimeout: opts.PollingTimeout}), nil
 }