Tag: system.reactive
System.Reaktive bezieht sich auf die Reactive Extensions for .NET, auch bekannt als Rx. Rx bietet Entwicklern mit einem reaktiven Programmierung-Modell über das generische IObservable<T> – Schnittstelle, im Gegensatz zur traditionellen, imperative Programmierung-Modell oder das andere reaktive Programmierung Modelle, die sich streng auf .NET Ereignisse oder spezifische APIs.
Synchronität in RxJS
1 Antworten
Ich würde erwarten, dass der folgende code asynchron ausführen: var range = Rx.Observable.range(0, 3000000); range.subscribe( function(x) {}, function(err) {}, function() { console.log('Completed'); }); console.log('Hello World'); Aber das ist nicht der Fall. Es dauert eine Weile, um durch
Rx durch ein Abonnement
1 Antworten
Was ist die empfohlene Art der Entsorgung von Abonnements erstellt werden, die in einer Schleife? Im folgenden Beispiel erfundene ich bin die Generierung von Abonnements in einer for-Schleife und hinzufügen zu einer List und entsorgen Sie ausdrücklich
wie konvertieren von IEnumerable zu IObservable?
2 Antworten
Ich bin auf der Suche zu konvertieren, die eine IEnumerable-Auflistung, um ein IObservable eine ohne Verwendung von Rx ToObservable() und ToEnumerable () - Methoden. Warum würden Sie nicht wollen, zu verwenden ToObservable()? Ich gebe zu, ich bin
Ist es Rx.NET für .NET-Core?
1 Antworten
Gefunden https://github.com/Reactive-Extensions/Rx.NET/issues/148, aber ich konnte nicht herausfinden, die untere Linie - wo ist Rx.NET für .NETTO-Kern-und wie Sie es bekommen? Ich bin mit Enterprise Visual Studio 2015 Update 3 mit .NET Core installiert. Haben Sie sich auf
ReactiveUI (RxUI) vs Reactive Extensions
1 Antworten
Vom http://docs.reactiveui.net/en/index.html : ReactiveUI ist ein MVVM-framework, das ermöglicht Ihnen die Verwendung des Reaktiven Erweiterungen für .NET zu erstellen elegant, testbare User-Interfaces, die führen Sie auf jedem mobilen oder desktop-Plattform. Ist RxUI irgendwie unterscheidet sich von Reactive
Vorteile .NETTO-Rx über die klassische Ereignisse?
4 Antworten
.NET 4.0 beta 2 hat eingeführt die IObservable und IObserver Schnittstellen. Was sind die Vorteile im Vergleich zu klassischen .NET-events? Dies nicht dasselbe problem zu lösen? Von einem cross-Technologie-Perspektive, Rx kann (und hat) umgesetzt, um die gleichen
Rx für .NET - Was ist Scheduler.Dispatcher?
2 Antworten
Ich versuche, die Arbeit durch Dan Sullivan ' s Rx-Erweiterungen Schulung auf PluralSight. Ist es eine gute Sachen, aber leider Rx scheint bereits geändert, obwohl der Kurs wurde nur veröffentlicht vor einem Monat. Meisten änderungen sind trivial
Wie behandeln Sie Ausnahmen, die ausgelöst durch Beobachter onNext in RxJava?
1 Antworten
Betrachten Sie das folgende Beispiel: Observable.range(1, 10).subscribe(i -> { System.out.println(i); if (i == 5) { throw new RuntimeException("oops!"); } }, Throwable::printStackTrace); Diese Ausgaben zahlen von 1 bis 5 und dann druckt die Ausnahme. Was ich erreichen will
Einzelne RxJava entpacken von Objekt
2 Antworten
Ich denken kann, zwei Möglichkeiten, um den Wert von Einzelnen Single<HotelResult> observableHotelResult = apiObservables.getHotelInfoObservable(requestBody); final HotelResult hotelResults = new HotelResult[1]; singleHotelResult .subscribe(hotelResult -> { hotelResults[0] = hotelResult; }); Oder final HotelResult hotelResult = singleHotelResult .toBlocking() .value(); So
Mit Rx zu synchronisieren asynchrone Ereignisse
2 Antworten
Will ich Reactive Extensions for .NET (Rx) zu nutzen, und würde gerne ein bisschen input für Sie einige grundlegende Aufgaben. Um zu verdeutlichen, was ich versuche zu tun, ich habe ein erfundenes Beispiel, wo ich eine externe
Rx: Wie kann ich sofort reagieren, und zu drosseln, die nachfolgenden Anforderungen
9 Antworten
Ich würde gerne eine Rx-Abonnement kann auf ein Ereignis reagiert sofort, und dann ignorieren die nachfolgenden Ereignisse, die geschehen, innerhalb eines bestimmten "cooldown" - Zeit. Den out-of-the-box-Drossel/Puffer Methoden nur zu reagieren, sobald das Zeitlimit abgelaufen ist, das
Ist das Reaktive Framework (RX) für den Einsatz in der Mono-noch?
5 Antworten
Gesucht, aber das einzige, was ich fand, war http://evain.net/blog/articles/2009/07/30/rebasing-system-reactive-to-the-net-clr, die ich habe zu arbeiten, aber es fühlt sich an wie es sollte ein einfacher Weg, besonders da rx war die erste Veröffentlichung zurück, in der Mitte 09.
TPL vs Reaktive Framework
5 Antworten
Als würde man verwenden, wählen Sie Rx über TPL oder sind die 2 Rahmenbedingungen orthogonal? Was ich verstehen Rx ist hauptsächlich vorgesehen, um eine Abstraktion über die Ereignisse und ermöglichen die Komposition, sondern es ermöglicht auch die
Wie zu verwenden zu Beobachten.FromEvent statt FromEventPattern und vermeiden Sie string-literal event-Namen
1 Antworten
Bin ich lernen, meinen Weg in Rx in WinForms und habe den folgenden code ein: //Create an observable from key presses, grouped by the key pressed var groupedKeyPresses = Observable.FromEventPattern<KeyPressEventArgs>(this, "KeyPress") .Select(k => k.EventArgs.KeyChar) .GroupBy(k => k);
Was sind die warmen und Kalten observablen?
4 Antworten
Ich sah das video und ich weiß, dass die Allgemeinen Grundsätze - hot passiert auch, wenn niemand angemeldet ist, kalten geschieht "on demand". Auch, Publish() konvertiert kalt zu warm und zu Verschieben() konvertiert heiß zu kalt. Aber
IObservable vs Plain Veranstaltungen oder Warum Sollte ich IObservable?
1 Antworten
Führte Microsoft IObservable<T> interface der BCL mit .NET Framework 4, und ich dachte, "Super, endlich muss ich es nutzen!" So grub ich tief und Lesen Sie Beiträge und Dokumentation und auch umgesetzt, die dem Muster. Nach tun,
Wie erstellen Sie Beobachten von der Funktion?
3 Antworten
Möchte ich eine Funktion aufrufen (synchron) und dann mit dessen Rückgabewert als eine erste emission (anschließend Verkettung einigen anderen Anbietern, die daraus resultierenden messbaren). Ich soll zum aufrufen dieser Funktion im Abonnement, ich kann also nicht einfach
Warum könnten System.Threading.dll fehlen Windows\Assembly?
2 Antworten
Ich habe verschiedene Versionen von der .NET Framework (Versionen 1.1 thru 4.0) Installation auf einer remote-Maschine mit XP Professional. Ich habe installiert Reaktive Erweiterung auch für eine gute Maßnahme. Ich habe auch eine Anwendung, die funktioniert auf
Howto Rückruf async-Funktion von rx zu abonnieren?
3 Antworten
Würde ich mag, um den Anruf wieder eine async-Funktion innerhalb eines Rx-Abonnement. E. g. so: public class Consumer { private readonly Service _service = new Service(); public ReplaySubject<string> Results = new ReplaySubject<string>(); public void Trigger() { Observable.Timer(TimeSpan.FromMilliseconds(100)).Subscribe(async
Wie Drossel-event-stream mit RX?
8 Antworten
Will ich effektiv Drosselklappe ein event-stream, so dass mein Delegat, der aufgerufen wird, wenn das erste Ereignis empfangen, aber dann nicht für 1 Sekunde, wenn die nachfolgenden Ereignisse empfangen werden. Nach Ablauf des timeout (1 Sekunde), wenn
Wie man ein thread warten, bis eine variable erreicht mit einer Reihe von Werten .NET/Csharp
5 Antworten
Ich geschrieben habe eine Klasse, die eine Eigenschaft des Typs TProperty und ein Ereignis vom Typ Action<TProperty> dass feuert, wenn diese Eigenschaft sich ändert. TProperty ist in der Regel ein enum-Typ, aber das sollte keine Rolle spielen.
Wie zum Hohn WCF-client über Moq?
1 Antworten
In meinem Projekt verwende ich: SL5+ MVVM+ PRISMA + WCF + Rx + Moq + Silverlight Unit Test Framework. Ich bin neu in unit-Tests und habe vor kurzem angefangen, in DI, Muster (MVVM) - etc. Daher ist
RxJava - Strahlen eine beobachtbare jede Sekunde
3 Antworten
Mache ich einen timer in Android mit RxJava. Ich brauche, um ein timer in RxJava zu emittieren, eine beobachtbare jede Sekunde. Ich habe Folgendes versucht, aber ohne Glück. Irgendwelche Gedanken auf, was ich falsch mache? Observable.interval(1000L, TimeUnit.MILLISECONDS)
IObserver und IObservable in C# für den Betrachter vs Delegierten, Veranstaltungen
2 Antworten
Alles was ich versuche zu tun, ist die Implementierung des observer-Musters. So, ich kam mit dieser Lösung: Haben wir eine PoliceHeadQuarters, deren primäre Aufgabe ist das senden von Benachrichtigungen an alle diejenigen, die er abonniert. Bedenken Sie,
RxJava und parallele Ausführung von Beobachter-code
5 Antworten
Ich bin mit dem folgenden code verwenden RxJava Observable api : Observable<Info> observable = fileProcessor.processFileObservable(processedFile.getAbsolutePath()); observable .buffer(10000) .observeOn(Schedulers.computation()) .subscribe(recordInfo -> { _logger.info("Running stage2 on thread with id : " + Thread.currentThread().getId()); for(Info info : recordInfo) { //some
Separate beobachtbaren Werte von bestimmten Zeitraum in RxJS
8 Antworten
Was wäre die idiomatische Weise ergeben Werte, für die erkennbar eine bestimmte Zeit? Zum Beispiel, sagen wir, ich habe eine Beobachtbare erstellt aus einem großen Array und ich möchte Ausbeute ein Wert alle 2 Sekunden. Ist eine
Die Umsetzung IObservable<T> von Grund auf
5 Antworten
Den Reactive Extensions kommen mit einer Menge helper Methoden für das drehen von vorhandenen Veranstaltungen und asynchrone Operationen in observablen, aber wie würden Sie bei der Implementierung eines IObservable<T> von Grund auf neu? IEnumerable hat die schönen
Angular2 Zu Beobachten.forkJoin der beobachtbaren Variablen - ReferenceError: Beobachten ist nicht definiert
3 Antworten
Ich möchte Sie bitten, für Hilfe. Ich ausgelassen code, den ich nehme, ist nicht wichtig. Stellen wir uns die TS-Datei enthält service-Aufrufe: //Datei: someService.ts @Injectable() export class SomeService { method1(){ var observable = this.http.get(someUrl) .map((res: Response) =><MyClass>res.json());
Wie funktioniert RxJava doOnError und onErrorReturn Arbeit?
1 Antworten
Habe ich diese unit-tests, und das Ergebnis ist nicht das, was ich erwartet habe: //This one outputs "subscribe.onError" @Test public void observable_doOnError_subscribingToError() throws InterruptedException { Observable<String> obs = getErrorProducingObservable(); obs.doOnError(throwable -> System.out.println("doOnError")); obs.subscribeOn(Schedulers.immediate()).observeOn(Schedulers.immediate()).subscribe( s -> {}, error
.NETZ, event, jede minute (auf die minute). Ist ein timer die beste option?
14 Antworten
Ich möchte Sachen tun, jede minute auf die minute (nach der Uhr) in einer windows forms-Anwendung mit c#. Ich Frage mich nur, was ist der beste Weg, um darüber zu gehen ? Könnte ich verwenden Sie einen
auf ein Observables warten
2 Antworten
So, in den traurigen Tagen von C# 4.0, ich habe die folgenden "WorkflowExecutor" - Klasse, die erlaubt asynchrone workflows in der GUI-thread durch hacken in IEnumerable "yield return" - Fortsetzungen zu warten observablen. Also der folgende code,
Warum werden Themen in .NET Reaktive Erweiterungen nicht empfohlen?
5 Antworten
Ich bin derzeit auf der Auseinandersetzung mit den Reactive Extensions framework für .NETTO und ich arbeite meinen Weg durch die verschiedenen Einführung Ressourcen, die ich gefunden habe (vor allem http://www.introtorx.com) Unsere Anwendung umfasst eine Reihe von hardware-Schnittstellen
Wie drosselt man Ereignisströme mit RX?
8 Antworten
Will ich effektiv Drosselklappe ein event-stream, so dass mein Delegat, der aufgerufen wird, wenn das erste Ereignis empfangen, aber dann nicht für 1 Sekunde, wenn die nachfolgenden Ereignisse empfangen werden. Nach Ablauf des timeout (1 Sekunde), wenn
Reaktive Erweiterung (Rx) Tutorial, das auf dem neuesten Stand ist
4 Antworten
Ich bin sehr daran interessiert, Reactive Extensions, aber ich kann nicht finden, eine up-to-date tutorial. Angefangen habe ich mit Die Heilung der asynchronen blues mit der Reactive Extensions for .NET aber es ist veraltet. Ich kann herausfinden,
Reaktive Observable Subscription Entsorgung
4 Antworten
Wenn ich Zugriff auf ein IObservable, die ich kenne, ist immer nur wieder ein Element, wird das funktionieren und ist es die beste Verwendung Muster? IDisposable disposable = null; disposable = myObservable.Subscribe(x => { DoThingWithItem(x); if (disposable
EventBus / PubSub vs (reaktive Erweiterungen) RX in Bezug auf Code Klarheit in einer Single-Thread-Anwendung
4 Antworten
Derzeit bin ich mit einem EventBus/PubSub Architektur/Muster mit Scala (und JavaFX) implementieren Sie eine einfache Notiz app organisieren (so in der Art wie ein Evernote-client mit einigen zusätzlichen mind-mapping-Funktionalität) und ich muss sagen, dass ich wirklich gerne
101 Rx Beispiele
7 Antworten
EDIT: Danke für den link zur wiki, ich denke, da Ihr schon angefangen es einfacher, dorthin zu gehen, check it out. Aber die Frage hier ist auch gut, damit Leute die nicht rund um die msdn-Foren kennen
Reaktive Erweiterungen (Rx) + MVVM =?
5 Antworten
Eines der wichtigsten Beispiele verwendet, um zu erklären, die macht von Reactive Extensions (Rx) ist die Kombination von vorhandenen Maus-Ereignisse in ein neues 'Ereignis' darstellt deltas, die beim ziehen per Maus: var mouseMoves = from mm in
Wann sollte Observable.FromEventPattern anstelle von Observable.FromEvent verwendet werden?
3 Antworten
Wir haben einen client-Aufruf aus, um einen TIBCO EMS Warteschlange und Verkabelung der Veranstaltungen wie diese: var msgConsumer = _session.CreateConsumer(responseQueue); var response = Observable.FromEvent<EMSMessageHandler,EMSMessageEventArgs> (h => msgConsumer.MessageHandler += h, h => msgConsumer.MessageHandler -= h) .Where(arg => arg.Message.CorrelationID
Was ist der Unterschied zwischen SubscribeOn und ObserveOn?
3 Antworten
Ich habe gerade entdeckt SubscribeOndas macht mich Frage mich, ob ich mit sollte, statt ObserveOn. Google hat mich hier und hieraber weder haben mir geholfen, zu verstehen der Unterschied: es scheint unglaublich subtil. (In meinen Kontext, ich
Gutes Beispiel für die Verwendung reaktiver Erweiterungen
6 Antworten
Verstehe ich die Grundlagen der Rx. Wo ich zu kämpfen ist, wie Sie tatsächlich nutzen diese auch außerhalb der akademischen Beispiele? Was sind einige einfachen real-world-Szenarien, in denen Rx ist eine viel bessere Lösung als das, was
C # .NET Rx - Wo ist System.Reactive?
2 Antworten
Habe ich eine intensive Java-hintergrund, so verzeihen Sie mir, wenn ich etwas Blick offensichtlich in C#, aber meine Forschung ist mir immer nirgends. Ich bin versucht, die reaktive Rx .NET-Bibliothek. Der compiler jammert nicht über die IObservable
Gute Einführung in das .NET Reactive Framework
16 Antworten
Abgesehen von der Dokumentation von Microsoft, gibt es eine gute Einführung und Tutorials zu den Microsoft-Reaktive (Rx) framework? Außerdem, was ist ein gutes Beispiel (mit code), dass Reaktive erleichtert eine Programmierung problem, die Herausforderung zu lösen, die
ObserveOn und SubscribeOn - wo die Arbeit gemacht wird
3 Antworten
Basierend auf dem Lesen dieser Frage: Was ist der Unterschied zwischen SubscribeOn und ObserveOn ObserveOn Sätze, wo der code ist in der Subscribe - handler wird ausgeführt: stream.Subscribe(_ => { //this code here }); Den SubscribeOn Methode