代码之家 › 专栏 › 技术社区 › user584018

这段代码是否适用于使用Rx核心的UdpClient

system.reactive udp c#

user584018 · 技术社区 · 7 年前

下面的代码是否正确,我正在对其进行一些设置 UdpClient 然后使用 Observable.Using(() ?

请建议是否有其他方式写它?

public static IObservable<UdpReceiveResult> UdpStream()
    {

        return Observable.Defer(() =>
        {
            UdpClient receiverUDP = new UdpClient();
            receiverUDP.Client.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, true);
            receiverUDP.EnableBroadcast = true;
            receiverUDP.Client.ExclusiveAddressUse = false;
            receiverUDP.Client.Bind(new IPEndPoint(IPAddress.Any, 514));


            return Observable.Using(() => receiverUDP,
                udpClient => Observable.Defer(() =>
                    udpClient.ReceiveAsync().ToObservable()).Repeat());
        });

    }

1 回复 | 直到 7 年前

Enigmativity 7 年前

根据意见中的要求:

public static IObservable<UdpReceiveResult> UdpStream()
{
    return Observable.Defer(() =>
    {
        UdpClient receiverUDP = new UdpClient();
        receiverUDP.Client.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, true);
        receiverUDP.EnableBroadcast = true;
        receiverUDP.Client.ExclusiveAddressUse = false;
        receiverUDP.Client.Bind(new IPEndPoint(IPAddress.Any, 514));

        return
            Observable
                .Using(
                    () => receiverUDP,
                    udpClient =>
                        Observable
                            .Defer(() =>
                                Observable
                                    .FromAsync(() => udpClient.ReceiveAsync()))
                            .Repeat());
    });
}

就我个人而言,我会这样做:

public static IObservable<UdpReceiveResult> UdpStream()
{
    return
        Observable
            .Using(
                () =>
                {
                    UdpClient receiverUDP = new UdpClient();
                    receiverUDP.Client.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, true);
                    receiverUDP.EnableBroadcast = true;
                    receiverUDP.Client.ExclusiveAddressUse = false;
                    receiverUDP.Client.Bind(new IPEndPoint(IPAddress.Any, 514));
                    return receiverUDP;
                },
                udpClient =>
                    Observable
                        .Defer(() =>
                            Observable
                                .FromAsync(() => udpClient.ReceiveAsync()))
                        .Repeat());
}

推荐文章

Robert King · Unity C#语法问题-转换位置

1 年前

JBryanB · 如何从基本抽象类访问类属性

1 年前

Anders Sewerin Johansen · 使用Moq提供一个利用mock的具体对象

1 年前

Community wiki · 基于两个参数在文本框中使用上下文键自动完成?

1 年前

Community wiki · SqlConnections,Parallel.For,一个旧的C#应用程序,初始化SqlConnections时随机挂起

1 年前

kling · LINQ生成的IEnumerable与原始列表之间的关系是什么?[副本]

1 年前

Adil15 · 以下方法和属性之间的调用不明确-Linq和MoreLinq

2 年前

law · 检查答案按钮的输入字符串格式不正确

2 年前

Laurian Avrigeanu · 如何执行嵌套的ContextMenu实现?

2 年前

i_sniff_ket · 在unity之外使用unity类

2 年前