diff --git a/pkg/channels/README.md b/pkg/channels/README.md index b654ad152..c4d12ef59 100644 --- a/pkg/channels/README.md +++ b/pkg/channels/README.md @@ -253,10 +253,10 @@ func (c *TelegramChannel) Stop(ctx context.Context) error { ```go // Old code: returned only error -func (c *TelegramChannel) Send(ctx context.Context, msg bus.OutboundMessage) ([]string, error) { - if !c.running { return nil, fmt.Errorf("not running") } +func (c *TelegramChannel) Send(ctx context.Context, msg bus.OutboundMessage) error { + if !c.running { return fmt.Errorf("not running") } // ... - if err != nil { return nil, err } + if err != nil { return err } } // New code: return delivered message IDs plus sentinel errors diff --git a/pkg/channels/README.zh.md b/pkg/channels/README.zh.md index 163781164..3edc5cb6b 100644 --- a/pkg/channels/README.zh.md +++ b/pkg/channels/README.zh.md @@ -253,10 +253,10 @@ func (c *TelegramChannel) Stop(ctx context.Context) error { ```go // 旧代码:只返回 error -func (c *TelegramChannel) Send(ctx context.Context, msg bus.OutboundMessage) ([]string, error) { - if !c.running { return nil, fmt.Errorf("not running") } +func (c *TelegramChannel) Send(ctx context.Context, msg bus.OutboundMessage) error { + if !c.running { return fmt.Errorf("not running") } // ... - if err != nil { return nil, err } + if err != nil { return err } } // 新代码:返回投递后的消息 ID,以及供 Manager 判断重试策略的哨兵错误