@@ -335,7 +335,13 @@ func TestUDPNetworkUnboundClientAPI(t *testing.T) {
335335 require .NotEqual (t , conn1 , conn2 )
336336
337337 {
338- res , err := udpWrite (ctx , nil , []any {conn1 , "127.0.0.1" , 9901 , []byte ("Hello" )})
338+ res , err := udpBeginPacket (ctx , nil , []any {conn1 , "127.0.0.1" , 9901 })
339+ require .Nil (t , err )
340+ require .True (t , res .(bool ))
341+ res , err = udpWrite (ctx , nil , []any {conn1 , []byte ("Hello" )})
342+ require .Nil (t , err )
343+ require .Equal (t , 5 , res )
344+ res , err = udpEndPacket (ctx , nil , []any {conn1 })
339345 require .Nil (t , err )
340346 require .Equal (t , 5 , res )
341347 }
@@ -353,12 +359,24 @@ func TestUDPNetworkUnboundClientAPI(t *testing.T) {
353359 require .Equal (t , []uint8 ("llo" ), res2 )
354360 }
355361 {
356- res , err := udpWrite (ctx , nil , []any {conn1 , "127.0.0.1" , 9901 , []byte ("One" )})
362+ res , err := udpBeginPacket (ctx , nil , []any {conn1 , "127.0.0.1" , 9901 })
363+ require .Nil (t , err )
364+ require .True (t , res .(bool ))
365+ res , err = udpWrite (ctx , nil , []any {conn1 , []byte ("One" )})
366+ require .Nil (t , err )
367+ require .Equal (t , 3 , res )
368+ res , err = udpEndPacket (ctx , nil , []any {conn1 })
357369 require .Nil (t , err )
358370 require .Equal (t , 3 , res )
359371 }
360372 {
361- res , err := udpWrite (ctx , nil , []any {conn1 , "127.0.0.1" , 9901 , []byte ("Two" )})
373+ res , err := udpBeginPacket (ctx , nil , []any {conn1 , "127.0.0.1" , 9901 })
374+ require .Nil (t , err )
375+ require .True (t , res .(bool ))
376+ res , err = udpWrite (ctx , nil , []any {conn1 , []byte ("Two" )})
377+ require .Nil (t , err )
378+ require .Equal (t , 3 , res )
379+ res , err = udpEndPacket (ctx , nil , []any {conn1 })
362380 require .Nil (t , err )
363381 require .Equal (t , 3 , res )
364382 }
@@ -384,7 +402,13 @@ func TestUDPNetworkUnboundClientAPI(t *testing.T) {
384402 // Check timeouts
385403 go func () {
386404 time .Sleep (200 * time .Millisecond )
387- res , err := udpWrite (ctx , nil , []any {conn1 , "127.0.0.1" , 9901 , []byte ("Three" )})
405+ res , err := udpBeginPacket (ctx , nil , []any {conn1 , "127.0.0.1" , 9901 })
406+ require .Nil (t , err )
407+ require .True (t , res .(bool ))
408+ res , err = udpWrite (ctx , nil , []any {conn1 , []byte ("Three" )})
409+ require .Nil (t , err )
410+ require .Equal (t , 5 , res )
411+ res , err = udpEndPacket (ctx , nil , []any {conn1 })
388412 require .Nil (t , err )
389413 require .Equal (t , 5 , res )
390414 }()
0 commit comments