직선 메서드를 사용하여 관찰 가능 객체 만들기

Question

메서드에 호출하는 일부 데이터를 웹 서비스에 연결하려고 생각합니다.

문제 :이 원격 수집 정보에 따라 레이블 컨트롤의 내용 텍스트를 업데이트해야한다고 상상해보십시오. 이 모든 데이터가 다시 수집 될 때까지는 레이블을 표시 할 수 없습니다.

원하는 내용 : 기본 텍스트로 라벨을 먼저 표시하고 싶습니다.이 정보를 수신함에 따라 라벨 내용을 업데이트하고 싶습니다. (제발,이 설명을 흡입 코드로 사용하지 마십시오. , 나는 나의 실제 상황을 간략하게하려고 노력하고있다).

나는이 방법의 관찰 가능한 순서를 만들고 싶습니다. 그럼에도 불구하고이 방법은 동일한 서명이 아닙니다. 예를 들어 :

int GetInt() { 
    return service.GetInt(); 
} 

string GetString() { 
    return service.GetString(); 
} 

string GetString2 { 
    return service.GetString2(); 
} 

이러한 방법은 async는 없습니다.

1. 관찰 가능한 순서를 만들 수 있습니까?

2. 어떻게 만들 수 있습니까?

3. 그럼에도 불구하고, 내 목표를 달성하는 가장 좋은 방법은 무엇입니까?

Answer 1

서비스에 대한 래퍼 클래스를 만들어서 값을 별도의 관찰 가능 항목으로 표시하는 방법을 살펴 보겠습니다.

그래서, 서비스 인터페이스로 시작 :

public interface IService 
{ 
    int GetInt(); 
    string GetString(); 
    string GetString2(); 
} 

을 ...다음은 ServiceWrapper 쓰기 :

public class ServiceWrapper : IService 
{ 
    private IService service; 
    private Subject<int> subjectGetInt = new Subject<int>(); 
    private Subject<string> subjectGetString = new Subject<string>(); 
    private Subject<string> subjectGetString2 = new Subject<string>(); 

    public ServiceWrapper(IService service) 
    { 
     this.service = service; 
    } 

    public int GetInt() 
    { 
     var value = service.GetInt(); 
     this.subjectGetInt.OnNext(value); 
     return value; 
    } 

    public IObservable<int> GetInts() 
    { 
     return this.subjectGetInt.AsObservable(); 
    } 

    public string GetString() 
    { 
     var value = service.GetString(); 
     this.subjectGetString.OnNext(value); 
     return value; 
    } 

    public IObservable<string> GetStrings() 
    { 
     return this.subjectGetString.AsObservable(); 
    } 

    public string GetString2() 
    { 
     var value = service.GetString2(); 
     this.subjectGetString2.OnNext(value); 
     return value; 
    } 

    public IObservable<string> GetString2s() 
    { 
     return this.subjectGetString2.AsObservable(); 
    } 
} 

을 이제 현재 서비스가 Service라고 가정, 당신은 일을 설정하려면이 코드를 작성합니다

이

IService service = new Service(); 
ServiceWrapper wrapped = new ServiceWrapper(service); // Still an `IService` 

var subscription = 
    Observable 
     .Merge(
      wrapped.GetInts().Select(x => x.ToString()), 
      wrapped.GetStrings(), 
      wrapped.GetString2s()) 
     .Subscribe(x => label.Text = x); 

IService wrappedService = wrapped; 

이제 코드에 service를 wrappedService을 통과하는 대신 . 여전히 기본이되는 service 코드이므로 다시 쓸 필요는 없습니다. 그러나 여전히 원하는 관찰 대상을 얻고 있습니다.

이것은 실제로 4 개의 갱인 decorator pattern입니다.

Answer 2

Observable.Create으로 사용자 정의 관찰 가능 시퀀스를 생성 할 수 있습니다. 귀하의 요구 사항을 사용하는 예는 다음과 같습니다 : 나는 getXXX 메소드의 각으로 Thread.Sleep 전화를 도입함으로써 네트워크 지연을 모방 얼마나

private int GetInt() 
{ 
    Thread.Sleep(1000); 

    return 1; 
} 

private string GetString() 
{ 
    Thread.Sleep(1000); 

    return "Hello"; 
} 

private string GetString2() 
{ 
    Thread.Sleep(2000); 

    return "World!"; 
} 

private IObservable<string> RetrieveContent() 
{ 
    return Observable.Create<string>(
     observer => 
     { 
      observer.OnNext("Default Text"); 

      int value = GetInt(); 

      observer.OnNext($"Got value {value}. Getting string..."); 

      string string1 = GetString(); 

      observer.OnNext($"Got string {string1}. Getting second string..."); 

      string string2 = GetString2(); 

      observer.OnNext(string2); 
      observer.OnCompleted(); 

      return Disposable.Empty; 
     } 
    ); 
} 

참고. 당신이로 가입해야합니다,이 관측에 가입 할 때 UI가 응답하지 않도록하기 위하여 다음과

이

IDisposable subscription = RetrieveContent() 
    .SubscribeOn(TaskPoolScheduler.Default) 
    .ObserveOn(DispatcherScheduler.Current) 
    .Subscribe(text => Label = text); 

이 코드는 관찰 순서를 시작하는 TaskPool을 스레드를 사용하는 .SubscribeOn(TaskPoolScheduler.Default) 확장 방법을 사용하고 차단됩니다 Thread.Sleep을 호출하지만 UI 스레드가 아니기 때문에 UI는 응답 성이 유지됩니다. 그런 다음 UI 스레드에서 UI를 업데이트하기 위해 (데이터 바인딩 된) Label 속성을 설정하기 전에 ".ObserveOn (DispatcherScheduler.Current)"을 사용하여 UI 스레드에 업데이트를 호출합니다.

희망 사항이 당신이 찾고있는 것이지만, 의견이 있으면 남겨 두어 더 도움을 드리겠습니다.