Improve multiplex

This commit is contained in:
世界
2023-04-20 11:16:22 +08:00
parent d21b521e33
commit c18a74a006
18 changed files with 155 additions and 1200 deletions

View File

@@ -19,7 +19,7 @@ func TestUDPNatClose(t *testing.T) {
defer cancel()
connCtx, connCancel := common.ContextWithCancelCause(context.Background())
defer connCancel(net.ErrClosed)
service := udpnat.New[int](ctx, 1, &testUDPNatCloseHandler{connCancel})
service := udpnat.New[int](1, &testUDPNatCloseHandler{connCancel})
service.NewPacket(ctx, 0, buf.As([]byte("Hello")), M.Metadata{}, func(natConn N.PacketConn) N.PacketWriter {
return &testPacketWriter{}
})