Remove unused 'ns' param in pubsub.New.

wetware · Jul 25, 2022 · 67c1d8d · 67c1d8d
1 parent 5f83dfc
commit 67c1d8d
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 5 deletions.
diff --git a/pkg/server/joiner.go b/pkg/server/joiner.go
@@ -60,7 +60,7 @@ func (j Joiner) Join(ctx context.Context, vat vat.Network, ps PubSub) (*Node, er
 
 	vat.Export(
 		pubsub_cap.Capability,
-		pubsub_cap.New(vat.NS, ps, pubsub_cap.WithLogger(logger)))
+		pubsub_cap.New(ps, pubsub_cap.WithLogger(logger)))
 
 	vat.Export(
 		cluster_cap.HostCapability,

diff --git a/pkg/vat/cap/pubsub/pubsub_bench_test.go b/pkg/vat/cap/pubsub/pubsub_bench_test.go
@@ -124,7 +124,7 @@ func BenchmarkPubSubCap(b *testing.B) {
 		pubsub.WithGossipSubProtocols(Subprotocols()))
 
 	require.NoError(b, err)
-	server := pscap.New(ns, ps)
+	server := pscap.New(ps)
 	defer server.Close()
 
 	client := pscap.PubSub{Client: server.Client()}
@@ -153,7 +153,7 @@ func BenchmarkPubSubCapNetwork(b *testing.B) {
 		pubsub.WithGossipSubProtocols(Subprotocols()))
 
 	require.NoError(b, err)
-	server := pscap.New(ns, ps)
+	server := pscap.New(ps)
 	defer server.Close()
 
 	left, right := transport.NewPipe(1)

diff --git a/pkg/vat/cap/pubsub/server.go b/pkg/vat/cap/pubsub/server.go
@@ -42,7 +42,7 @@ type Provider struct {
 	ts map[string]*refCountedTopic
 }
 
-func New(ns string, ps TopicJoiner, opt ...Option) *Provider {
+func New(ps TopicJoiner, opt ...Option) *Provider {
 	var f = &Provider{
 		cq: make(chan struct{}),
 		ps: ps,

diff --git a/pkg/vat/cap/pubsub/server_test.go b/pkg/vat/cap/pubsub/server_test.go
@@ -52,7 +52,7 @@ func TestPubSub_refcount(t *testing.T) {
 	gs, err := pubsub.NewGossipSub(ctx, h)
 	require.NoError(t, err)
 
-	p := pscap.New("test", gs, pscap.WithLogger(log))
+	p := pscap.New(gs, pscap.WithLogger(log))
 	defer func() {
 		assert.NoError(t, p.Close(), "factory should close gracefully")
 		assert.ErrorIs(t, p.Close(), pscap.ErrClosed)