Reactive Extensions for .NET (Rx): Take action once all events are completed

by

You can use Observable.When like so (I’ve added an additional CheckBox for this example):

var checkChanged  = Observable.FromEvent<EventArgs>(this.checkBox, "CheckedChanged");
var check1Changed = Observable.FromEvent<EventArgs>(this.checkBox1, "CheckedChanged");
var keyPress      = Observable.FromEvent<KeyPressEventArgs>(this.textBox, "KeyPress");

var plan1 = checkChanged
            .And(check1Changed).And(keyPress)
            .Then((cc, cc1, kp) => "Done.");

var when = Observable.When(plan1);

when.Subscribe((result) => this.resultTextBox.Text = result);

Also, if you can join other plans together, for example if things can be “done” when either one set of events fire, or also when another set of events fire:

var checkChanged  = Observable.FromEvent<EventArgs>(this.checkBox, "CheckedChanged");
var check1Changed = Observable.FromEvent<EventArgs>(this.checkBox1, "CheckedChanged");
var keyPress      = Observable.FromEvent<KeyPressEventArgs>(this.textBox, "KeyPress");
var keyPress1     = Observable.FromEvent<KeyPressEventArgs>(this.textBox1, "KeyPress");

var plan1 = checkChanged.And(check1Changed).And(keyPress).Then((cc, cc1, kp) => "Done.");
var plan2 = keyPress.And(keyPress1).Then((kp, kp1) => "Alternate done.");

var join = Observable.When(plan1, plan2);

More Related Contents:

  1. ObserveOn and SubscribeOn – where the work is being done
  2. How can I implement an exhaustMap handler in Rx.Net?
  3. Good introduction to the .NET Reactive Framework [closed]
  4. Does reactive extensions support rolling buffers?
  5. A way to push buffered events in even intervals
  6. Process.start: how to get the output?
  7. Question about terminating a thread cleanly in .NET
  8. Fast work with Bitmaps in C#
  9. Using RegEx to balance match parenthesis
  10. Why doesn’t .NET/C# optimize for tail-call recursion?
  11. Is it possible to compile and execute new code at runtime in .NET?
  12. How do I implement IEnumerable
  13. ASP.NET use SqlConnection connect MySQL
  14. TabControl with Close and Add Button
  15. Where can I find a free masked TextBox in WPF? [closed]
  16. Creating a temporary directory in Windows?
  17. What is the best practice for “Copy Local” and with project references?
  18. One class per file rule in .NET? [closed]
  19. Install to same path when upgrading application
  20. How to mix colors “naturally” with C#?
  21. Drawing on top of controls inside a panel (C# WinForms)
  22. Get IPrincipal from OAuth Bearer Token in OWIN
  23. Why “decimal” is not a valid attribute parameter type?
  24. Why does System.Threading.Timer stop on its own?
  25. System.IO.FileNotFoundException: Could not load file or assembly ‘X’ or one of its dependencies when deploying the application
  26. Why are structs stored on the stack while classes get stored on the heap(.NET)?
  27. Can you mix .net languages within a single project?
  28. Using reflection to get method name and parameters
  29. Best way to limit the number of active Tasks running via the Parallel Task Library
  30. How do I get a Video Thumbnail in .Net?

Leave a Comment