Langage C#
  1. Langage C#
  3. Entre les valeurs avec Rx
Intereting Posts
Hébergement d’un instrument VST / DX en C # / C ++? DevExpress XtraGrid Control avec la colonne checkBoxEdit convertisseur infixe en postfixe System.Speech in Mono sous Linux Obtenir la valeur liée de la propriété de classe, DefaultBindingProperty ne fonctionne pas pour moi! INotifyPropertyChanged et Threading Pourquoi MediaElement échoue-t-il parfois en silence et comment puis-je le corriger? Pourquoi devenir des contraintes référentielles incohérentes après la mise à jour de la clé étrangère? La classe WebClient n’existe pas dans Windows 8 C # Empêcher l’affichage d’Adobe Reader Window lorsque vous essayez d’imprimer un document Pourquoi .NET crée-t-il de nouvelles sous-chaînes au lieu de pointer vers des chaînes existantes? Remplir DropDownList à l’intérieur du répéteur ne fonctionne pas meilleur moyen d’accéder à la firebase database en utilisant SOAP Comment vais-je extraire les données du fichier docx en utilisant DocumentFormat.OpenXml -details ci-dessous Puis-je forcer le nettoyage de la mémoire en C #?

Entre les valeurs avec Rx

Existe-t-il une méthode d’extension dans Rx pour réaliser le scénario ci-dessous?

Entre les valeurs

J’ai une valeur pour démarrer le pompage (cercles verts) et une autre valeur pour arrêter le pompage (cercles en roseau), les cercles bleus doivent correspondre aux valeurs attendues. “SkipUntil” ne fonctionnera pas).

L’implémentation utilisant LINQ ressemblerait à ceci: 

public static IEnumerable TakeBetween(this IEnumerable source, Func entry, Func 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; } }

Comment cette même logique pourrait-elle IObservable à IObservable ?

Voici ce dont vous avez besoin comme méthode d’extension: 

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

L’essentiel que j’ai inclus dans ceci est l’utilisation de l’extension Publish . Dans ce cas particulier, il est important que votre source observable puisse être “chaude”, ce qui permet de partager les valeurs source sans créer plusieurs abonnements à la source.

Je pense que vous pouvez utiliser Window : 

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