有什么方法可以通过1个时间缓冲字符串和1个时间正则检查

Question

我的字符串表示 Encoding.UTF8.GetString(b.Buffer)的字符串表示是" foo：foo1" 。

我想针对Regex解析字符串，然后用RemoteData类的2个不同属性（Message1和Message2）绑定。

public class RemoteData
{
    private string _message1;
    private string _message2;
    public RemoteData(string Message1, string Message2)
    {
        this.Message1 = Message1;
        this.Message2 = Message2;
    }
    public string Message1
    {
        get
        {
            if (IsValidMessage(_message1))
                return _message1 = _message1.Split(':')[0].ToString();
            return _message1;
        }
        set
        {
            _message1 = value;
        }
    }
    public string Message2
    {
        get
        {
            if (IsValidMessage(_message2))
                return _message2 = _message2.Split(':')[1].ToString();
            return _message2;
        }
        set
        {
            _message2 = value;
        }
    }
    private static bool IsValidMessage(string value)
    {
        const string expression = (@"([w]+):([w]+)");
        return Regex.IsMatch(value, expression, RegexOptions.IgnoreCase);
    }
}

我正在返回RemoteData及以下代码的IObservable。

 public static IObservable<RemoteData> UdpStream(IPEndPoint endpoint)
    {
        return Observable.Using(() => new UdpClient(endpoint),
            udpClient => Observable.Defer(() =>
                udpClient.ReceiveAsync().ToObservable()).Repeat().Select(b => new RemoteData(Encoding.UTF8.GetString(b.Buffer), Encoding.UTF8.GetString(b.Buffer))));
    }

问题：有什么办法，

1. 我只能在Observable 中仅通过一次Encoding.UTF8.GetString(b.Buffer)>选择？
2. 我只需要进行一次以下时正时检查并将字符串转换为RemoteData类的各种属性？

谢谢！

Answer 1

作为解决方案，我正在使用另一个类SplitData并在RemoteData构造函数上检查正则是。

public class SplitData
{
    public string Message1 { get; set; }
    public string Message2 { get; set; }
}
public class RemoteData
{
    private SplitData _SplitData;
    public RemoteData(string Message)
    {
        this.Message = Message;
        if (IsValidMessage(this.Message))
        {
            _SplitData = new SplitData
            {
                Message1 = Message.Split(':')[0].ToString(),
                Message2 = Message.Split(':')[1].ToString()
            };
        }
    }
    public string Message { get; }
    public SplitData SplitData
    {
        get
        {
            return _SplitData;
        }
        set
        {
            _SplitData = value;
        }
    }
    private static bool IsValidMessage(string value)
    {
        const string expression = (@"([w]+):([w]+)");
        return Regex.IsMatch(value, expression, RegexOptions.IgnoreCase);
    }
}

并将一个参数传递给UdpStream方法，

public static IObservable<RemoteData> UdpStream(IPEndPoint endpoint)
    {
        return Observable.Using(() => new UdpClient(endpoint),
            udpClient => Observable.Defer(() =>
                udpClient.ReceiveAsync().ToObservable()).Repeat().Select(b => new RemoteData(Encoding.UTF8.GetString(b.Buffer))));
    }

请让我知道是否有其他更好的方法。谢谢！