Commit 140a141c authored by Brian Tiger Chow's avatar Brian Tiger Chow Committed by Jeromy

style(bitswap/notifications) make it more obvious

License: MIT
Signed-off-by: default avatarBrian Tiger Chow <brian@perfmode.com>
parent 6ee1fe5e
...@@ -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 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