Между значениями с Rx

Question

Есть ли какой-нибудь метод расширения в Rx, чтобы сделать сценарий ниже?

У меня есть значение, чтобы начать накачка (зеленые кружки) и другое значение, чтобы остановить накачки (тростниковые круги), синие круги должны быть ожидаемые значения, я не хотел бы эту команду, чтобы быть отменены и воссозданы (т.е. «TakeUntil» и «SkipUntil» не будут работать).

Реализация с помощью LINQ будет что-то вроде этого:

public static IEnumerable<T> TakeBetween<T>(this IEnumerable<T> source, Func<T, bool> entry, Func<T, bool> exit) 
    { 
     bool yield = false; 
     foreach (var item in source) 
     { 
      if (!yield) 
      { 
       if (!entry(item)) 
        continue; 

       yield = true; 
       continue; 
      } 

      if (exit(item)) 
      { 
       yield = false; 
       continue; 
      } 

      yield return item; 
     } 
    } 

Как это та же логика для IObservable<T>?

Answer 1

Вот что вам нужно, как метод расширения:

public static IObservable<T> TakeBetween<T>(
    this IObservable<T> source, 
    Func<T, bool> entry, 
    Func<T, bool> exit) 
{ 
    return source 
     .Publish(xs => 
     { 
      var entries = xs.Where(entry); 
      var exits = xs.Where(exit); 
      return xs.Window(entries, x => exits); 
     }) 
     .Switch(); 
} 

Главное я включил в это Использованный расширения Publish , В этом конкретном случае это важно, так как ваш наблюдаемый источник может быть «горячим», и это позволяет делиться исходными значениями без создания нескольких подписей на источник.

Answer 2

Я думаю, что вы можете использовать Window:

source.Window(entrySignal, _ => exitSignal).Switch();