코드 조각이 Rx-Core를 사용하는 UdpClient에 맞습니까?

Question

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()); 
     }); 

    } 

Answer 1

을 :

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()); 
}