• Jobs
  • About Us
  • professionals
    • Home
    • Jobs
    • Courses and challenges
  • business
    • Home
    • Post vacancy
    • Our process
    • Pricing
    • Assessments
    • Payroll
    • Blog
    • Sales
    • Salary Calculator

0

178
Views
¿Cómo combinar secuencias IObservables en UniRx/Rx.NET?

Estoy usando el sabor UniRx de Reactive Extensions para el motor de juego Unity3D. Unity usa C#, así que supongo que es similar a Rx.NET.

Necesito una forma más hermosa de verificar cuándo se completan varias secuencias observables.

En el siguiente ejemplo, una de las secuencias depende del resultado de la primera (ya que necesita un número entero para processID ).

Los observables son ambos de tipo IObservable<string> .

 var processListObservable = APIBuilder .GetProcessList(authInfo.Token, authInfo.PlatformURL, (int)product.Id) .Subscribe(listJson => { processList = ProcessList.FromJson(listJson); int processID = (int)processList.Processes[0].ProcessDataId; //Retrieve Detailed information of the first entry var processDetailsObservable = APIBuilder .GetProcessDetails(token, platformURL, product.Id, processID) .Subscribe(detailsJson => { processData = ProcessData.FromJson(detailsJson); SetupPlotView(); }); });

Cualquier pista sería muy apreciada. También algunas sugerencias para resolver el mismo escenario menos la dependencia del resultado de la primera secuencia.

about 3 years ago · Santiago Trujillo
1 answers
Answer question

0

En lugar de poner su código en el controlador Subscribe , podría hacerlo parte de la secuencia. Podría usar el operador Select para proyectar cada listJson a un IObservable<string> (lo que da como resultado un IObservable<IObservable<string>> anidado), y luego aplanar la secuencia usando el operador Concat o Merge , dependiendo de si desea evitar o permitir la concurrencia.

 var processListObservable = APIBuilder .GetProcessList(authInfo.Token, authInfo.PlatformURL, (int)product.Id) .Select(listJson => { var processList = ProcessList.FromJson(listJson); int processID = (int)processList.Processes[0].ProcessDataId; return APIBuilder.GetProcessDetails(token, platformURL, product.Id, processID); }) .Concat() // or .Merge() to allow concurrency .ObserveOn(SynchronizationContext.Current) // Optional .Do(detailsJson => { var processData = ProcessData.FromJson(detailsJson); SetupPlotView(processData); }); await processListObservable.DefaultIfEmpty(); // Start and await the operation

La await en la línea final provocará una suscripción implícita a processListObservable y su código se ejecutará como un efecto secundario de esta suscripción.

about 3 years ago · Santiago Trujillo Report
Answer question
Find remote jobs

Discover the new way to find a job!

Top jobs
Top job categories
Business
Post vacancy Pricing Our process Sales
Legal
Terms and conditions Privacy policy
© 2025 PeakU Inc. All Rights Reserved.

Andres GPT

Recommend me some offers
I have an error