From 75fcbf0c2cf3a8eeea77f1a740796eb2298ba566 Mon Sep 17 00:00:00 2001 From: Erin Swenson-Healey Date: Mon, 4 Jun 2018 14:14:54 -0700 Subject: [PATCH] New -> NewFloodsubWithProtocols --- floodsub.go | 6 +++--- floodsub_test.go | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/floodsub.go b/floodsub.go index 00637e3..65d640a 100644 --- a/floodsub.go +++ b/floodsub.go @@ -14,8 +14,8 @@ const ( FloodSubID = protocol.ID("/floodsub/1.0.0") ) -// New returns a new floodsub-enabled PubSub objecting using the protocols specified in ps -func New(ctx context.Context, h host.Host, ps []protocol.ID, opts ...Option) (*PubSub, error) { +// NewFloodsubWithProtocols returns a new floodsub-enabled PubSub objecting using the protocols specified in ps +func NewFloodsubWithProtocols(ctx context.Context, h host.Host, ps []protocol.ID, opts ...Option) (*PubSub, error) { rt := &FloodSubRouter{ protocols: ps, } @@ -24,7 +24,7 @@ func New(ctx context.Context, h host.Host, ps []protocol.ID, opts ...Option) (*P // NewFloodSub returns a new PubSub object using the FloodSubRouter func NewFloodSub(ctx context.Context, h host.Host, opts ...Option) (*PubSub, error) { - return New(ctx, h, []protocol.ID{FloodSubID}, opts...) + return NewFloodsubWithProtocols(ctx, h, []protocol.ID{FloodSubID}, opts...) } type FloodSubRouter struct { diff --git a/floodsub_test.go b/floodsub_test.go index baa7b40..e7b421f 100644 --- a/floodsub_test.go +++ b/floodsub_test.go @@ -681,7 +681,7 @@ func TestFloodSubPluggableProtocol(t *testing.T) { } func mustCreatePubSub(ctx context.Context, t *testing.T, h host.Host, ps ...protocol.ID) *PubSub { - psub, err := New(ctx, h, ps) + psub, err := NewFloodsubWithProtocols(ctx, h, ps) if err != nil { t.Fatal(err) }