提交 85229be4 作者: Brian Tiger Chow 提交者: Jeromy

style(bitswap/notifications) make it more obvious

License: MIT
Signed-off-by: 's avatarBrian Tiger Chow <brian@perfmode.com>
上级 297ff3d4
...@@ -8,6 +8,8 @@ import ( ...@@ -8,6 +8,8 @@ import (
u "github.com/jbenet/go-ipfs/util" u "github.com/jbenet/go-ipfs/util"
) )
const bufferSize = 16
type PubSub interface { type PubSub interface {
Publish(block blocks.Block) Publish(block blocks.Block)
Subscribe(ctx context.Context, k u.Key) <-chan blocks.Block Subscribe(ctx context.Context, k u.Key) <-chan blocks.Block
...@@ -15,7 +17,6 @@ type PubSub interface { ...@@ -15,7 +17,6 @@ type PubSub interface {
} }
func New() PubSub { func New() PubSub {
const bufferSize = 16
return &impl{*pubsub.New(bufferSize)} return &impl{*pubsub.New(bufferSize)}
} }
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论