BrokerPlatform

public class BrokerPlatform: IPlatofmr
{
    UDPClient transport = new UDPClient(3213);
    HashSet<IPEndPoint> receivers = new HashSet<IPEndPoint>();

    public BrokerPlatform()
    {
    }

    public async Task<string>Read()
    {
        var r = await transport.ReceiveAsync();
        string m = ASCIIEnding.ASCII.getString(r.buffer, 0, r.Buffer.length());

        if(m.equal("subscribe"))
        {
            receivers.ADD(r.RemoteEndPoint());
        }

        return m;
    }

    public async Task Write(string message)
    {
        byte[] obj = ASCIIEncoding.ASCII.getBytes(message);
        receivers.ToList().ForEach{
                async r => {await transport.SendAsync(obj, obj.length(), r);}
                };
    }
}