// +build ignore /* package drpc import ( "context" "net" "testing" drpc "github.com/unistack-org/micro-client-drpc/v3" protocodec "github.com/unistack-org/micro-codec-proto/v3" pb "github.com/unistack-org/micro-tests/client/drpc/proto" "github.com/unistack-org/micro/v3/client" "storj.io/drpc/drpcmux" "storj.io/drpc/drpcserver" ) type TestServer struct{} func (s *TestServer) Call(ctx context.Context, req *pb.CallReq) (*pb.CallRsp, error) { return &pb.CallRsp{Name: req.Name + " rsp"}, nil } func (s *TestServer) Hello(ctx context.Context, req *pb.CallReq) (*pb.CallRsp, error) { return &pb.CallRsp{Name: req.Name + " rsp"}, nil } func TestDrpc(t *testing.T) { t.Skip() ctx, cancel := context.WithCancel(context.Background()) defer cancel() m := drpcmux.New() ln, err := net.Listen("tcp", "127.0.0.1:0") if err != nil { t.Fatal(err) } defer ln.Close() err = pb.DRPCRegisterTestService(m, &TestServer{}) if err != nil { t.Fatal(err) } go func() { if err := drpcserver.New(m).Serve(ctx, ln); err != nil { t.Fatal(err) } }() c := client.NewClientCallOptions(drpc.NewClient(client.Codec("application/drpc+proto", protocodec.NewCodec())), client.WithAddress(ln.Addr().String())) cli := pb.NewTestServiceClient("test", c) rsp, err := cli.Call(ctx, &pb.CallReq{Name: "test_name"}) if err != nil { t.Fatal(err) } if rsp.Name != "test_name rsp" { t.Fatalf("unexpected rsp %#+v", rsp) } } */