Skip to content
Snippets Groups Projects
Commit 13d035dd authored by ktr0731's avatar ktr0731
Browse files

remove unnecessary code

parent 7639cbd3
No related branches found
No related tags found
No related merge requests found
......@@ -170,26 +170,6 @@ func TestClient(t *testing.T) {
assert.Equal(t, expected, extractMessage(t, res))
}
})
// t.Run("Send a client streaming API", func(t *testing.T) {
// client := NewClient(defaultAddr, withStubTransport(&stubTransport{
// res: readFile(t, "client_streaming_ktr.out"),
// }))
//
// // NOTE: in is a dummy input. actual input is above file.
// in, out := pkg.getMessageTypeByName(t, "SimpleRequest"), pkg.getMessageTypeByName(t, "SimpleResponse")
// req, err := NewRequest(endpoint, in, out)
// require.NoError(t, err)
//
// cs, err = client.ClientStream(context.Background(), req)
// require.NoError(t, err)
//
// names := []string{"ohana", "nako", "minko"}
// for _, name := range names {
// cs.Send()
// }
// cs.Close()
// })
}
func TestClientE2E(t *testing.T) {
......
package main
import (
"context"
"github.com/jhump/protoreflect/desc"
"github.com/jhump/protoreflect/desc/protoparse"
"github.com/k0kubun/pp"
"github.com/ktr0731/grpc-test/api"
"github.com/ktr0731/grpc-web-go-client/grpcweb"
)
func parseProto(fname string) []*desc.FileDescriptor {
p := &protoparse.Parser{
ImportPaths: []string{"."},
}
d, err := p.ParseFiles(fname)
if err != nil {
panic(err)
}
return d
}
func main() {
desc := parseProto("grpcweb/testdata/api.proto")
client := grpcweb.NewClient("localhost:50051")
svc := desc[0].GetServices()[0].AsServiceDescriptorProto()
in, out := &api.SimpleRequest{Name: "ktr0731"}, &api.SimpleResponse{}
endpoint := grpcweb.ToEndpoint("api", svc, svc.Method[0])
req, err := grpcweb.NewRequest(endpoint, in, out)
if err != nil {
panic(err)
}
if err := client.Unary(context.Background(), req); err != nil {
panic(err)
}
pp.Println(out.GetMessage())
}
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment