Skip to content

Commit 93b00e2

Browse files
committed
fixed TestUDP
1 parent db11d25 commit 93b00e2

File tree

1 file changed

+12
-0
lines changed

1 file changed

+12
-0
lines changed

rpc/rpc_test.go

+12
Original file line numberDiff line numberDiff line change
@@ -669,6 +669,18 @@ func TestUnix(t *testing.T) {
669669

670670
func TestUDP(t *testing.T) {
671671
service := rpc.NewService()
672+
service.AddMissingMethod(func(name string, args []interface{}) (result []interface{}, err error) {
673+
data, err := json.Marshal(args)
674+
if err != nil {
675+
return nil, err
676+
}
677+
return []interface{}{name + string(data)}, nil
678+
})
679+
method := service.Get("*")
680+
assert.Equal(t, reflect.Func, method.Func().Kind())
681+
assert.Equal(t, []reflect.Type{reflect.TypeOf(""), reflect.TypeOf([]interface{}{})}, method.Parameters())
682+
assert.True(t, method.ReturnError())
683+
assert.Nil(t, method.Options())
672684
udpHandler := rpc.UDPHandler(service)
673685
udpHandler.OnClose = func(c net.Conn) {
674686
fmt.Println(c.LocalAddr().String() + " closed on server")

0 commit comments

Comments
 (0)