[WorldSystemFilter(WorldSystemFilterFlags.ClientSimulation)]
[BurstCompile]
public partial struct SystemConnect : ISystem
{
[BurstCompile]
public void OnCreate(ref SystemState state)
{
state.RequireForUpdate();
}
[BurstCompile]
public void OnUpdate(ref SystemState state)
{
var ebc = new EntityCommandBuffer(state.WorldUpdateAllocator);
foreach (var (cnn, entity) in SystemAPI.Query<RefRO>().WithAll().WithEntityAccess())
{
var connectRequest = state.World.EntityManager.CreateEntity(typeof(NetworkStreamRequestConnect));
ebc.AddComponent(connectRequest, new NetworkStreamRequestConnect { Endpoint = NetworkEndpoint.AnyIpv4.WithPort(12345) });
ebc.Playback(state.World.EntityManager);
ebc.Dispose();
}
}
}