Renamed udp/awaitRead -> udp/awaitPacket

Author: cmaglie

network-api/network-api.go

@@ -50,7 +50,7 @@ func Register(router *msgpackrouter.Router) {
 	_ = router.RegisterMethod("udp/beginPacket", udpBeginPacket)
 	_ = router.RegisterMethod("udp/write", udpWrite)
 	_ = router.RegisterMethod("udp/endPacket", udpEndPacket)
-	_ = router.RegisterMethod("udp/awaitRead", udpAwaitRead)
+	_ = router.RegisterMethod("udp/awaitPacket", udpAwaitPacket)
 	_ = router.RegisterMethod("udp/read", udpRead)
 	_ = router.RegisterMethod("udp/close", udpClose)
 }
@@ -475,7 +475,7 @@ func udpEndPacket(ctx context.Context, rpc *msgpackrpc.Connection, params []any)
 	}
 }
 
-func udpAwaitRead(ctx context.Context, rpc *msgpackrpc.Connection, params []any) (_result any, _err any) {
+func udpAwaitPacket(ctx context.Context, rpc *msgpackrpc.Connection, params []any) (_result any, _err any) {
 	if len(params) != 1 && len(params) != 2 {
 		return nil, []any{1, "Invalid number of parameters, expected (UDP connection ID[, optional timeout in ms])"}
 	}

network-api/network-api_test.go

@@ -259,7 +259,7 @@ func TestUDPNetworkAPI(t *testing.T) {
 		require.Equal(t, 5, res)
 	}
 	{
-		res, err := udpAwaitRead(ctx, nil, []any{conn2})
+		res, err := udpAwaitPacket(ctx, nil, []any{conn2})
 		require.Nil(t, err)
 		require.Equal(t, []any{5, "127.0.0.1", 9800}, res)
 
@@ -293,7 +293,7 @@ func TestUDPNetworkAPI(t *testing.T) {
 		require.Equal(t, 3, res)
 	}
 	{
-		res, err := udpAwaitRead(ctx, nil, []any{conn2})
+		res, err := udpAwaitPacket(ctx, nil, []any{conn2})
 		require.Nil(t, err)
 		require.Equal(t, []any{3, "127.0.0.1", 9800}, res)
 
@@ -302,7 +302,7 @@ func TestUDPNetworkAPI(t *testing.T) {
 		require.Equal(t, []uint8("One"), res2)
 	}
 	{
-		res, err := udpAwaitRead(ctx, nil, []any{conn2})
+		res, err := udpAwaitPacket(ctx, nil, []any{conn2})
 		require.Nil(t, err)
 		require.Equal(t, []any{3, "127.0.0.1", 9800}, res)
 
@@ -337,7 +337,7 @@ func TestUDPNetworkUnboundClientAPI(t *testing.T) {
 		require.Equal(t, 5, res)
 	}
 	{
-		res, err := udpAwaitRead(ctx, nil, []any{conn2})
+		res, err := udpAwaitPacket(ctx, nil, []any{conn2})
 		require.Nil(t, err)
 		require.Equal(t, 5, res.([]any)[0])
 
@@ -360,7 +360,7 @@ func TestUDPNetworkUnboundClientAPI(t *testing.T) {
 		require.Equal(t, 3, res)
 	}
 	{
-		res, err := udpAwaitRead(ctx, nil, []any{conn2})
+		res, err := udpAwaitPacket(ctx, nil, []any{conn2})
 		require.Nil(t, err)
 		require.Equal(t, 3, res.([]any)[0])
 
@@ -369,7 +369,7 @@ func TestUDPNetworkUnboundClientAPI(t *testing.T) {
 		require.Equal(t, []uint8("One"), res2)
 	}
 	{
-		res, err := udpAwaitRead(ctx, nil, []any{conn2})
+		res, err := udpAwaitPacket(ctx, nil, []any{conn2})
 		require.Nil(t, err)
 		require.Equal(t, 3, res.([]any)[0])
 
@@ -387,13 +387,13 @@ func TestUDPNetworkUnboundClientAPI(t *testing.T) {
 	}()
 	{
 		start := time.Now()
-		res, err := udpAwaitRead(ctx, nil, []any{conn2, 10})
+		res, err := udpAwaitPacket(ctx, nil, []any{conn2, 10})
 		require.Less(t, time.Since(start), 20*time.Millisecond)
 		require.Equal(t, []any{5, "Timeout"}, err)
 		require.Nil(t, res)
 	}
 	{
-		res, err := udpAwaitRead(ctx, nil, []any{conn2, 0})
+		res, err := udpAwaitPacket(ctx, nil, []any{conn2, 0})
 		require.Nil(t, err)
 		require.Equal(t, 5, res.([]any)[0])