Подтвердить что ты не робот

Reactive Extensions для .NET(Rx): принять меры после завершения всех событий

Как доказательство концепции, я хочу написать "Готово" в текстовом поле после того, как установлен флажок и нажата клавиша в текстовом поле (в любом порядке). Я бы ожидал, что этот код справится с этим, но он пишет Done, как только произойдет одно из событий. Благодарим за помощь.

var seq = Observable.FromEvent<EventArgs>(this.checkBox, "CheckedChanged")
   .Merge(Observable.FromEvent<KeyPressEventArgs>(this.textBox, "KeyPress"));

seq.Subscribe((unused) => this.resultTextBox.Text = "Done");

Ответ 1

Вы можете использовать Observable.When так (я добавил дополнительный CheckBox для этого примера):

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);

Кроме того, если вы можете присоединиться к другим планам вместе, например, если вещи могут быть "сделаны", когда один из огней событий, или также когда срабатывает другой набор событий:

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);

Ответ 2

если вам нужны оба события - подумайте об использовании Zip. Слияние приведет к событию, если любой объединенных источников поднимет его.