fix for latest micro

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
This commit is contained in:
2020-11-03 02:24:07 +03:00
parent 848ffcb6d7
commit 751b03d5a8
12 changed files with 214 additions and 60 deletions

View File

@@ -1,6 +1,7 @@
package tcp_test
import (
"context"
"fmt"
"io"
"net"
@@ -20,6 +21,7 @@ type testHandler struct {
}
func TestTCPServer(t *testing.T) {
ctx := context.Background()
reg := rmemory.NewRegistry()
brk := bmemory.NewBroker(broker.Registry(reg))
// create server
@@ -39,7 +41,7 @@ func TestTCPServer(t *testing.T) {
}
// lookup server
service, err := reg.GetService(server.DefaultName)
service, err := reg.GetService(ctx, server.DefaultName)
if err != nil {
t.Fatal(err)
}