Ссылка на предыдущие элементы. Есть ли какое-либо наблюдаемое расширение для этого в Rx или Rxx?

У меня есть IObservable, я ищу способ сделать что-то подобное

var referenceBack2 = source.Ref(2);

скажем, у меня есть эта последовательность в источнике

A-B-C-D-E-F-G-H

ReferenceBack2 не будет выполнять OnNext() для A до тех пор, пока B не пройдет через источник, не будет отображать B, пока не придет C, и в конце он будет отображать G. H будет ждать вечно, потому что A является горячим наблюдаемым, и после H нет элементов. .


observable system.reactive
person fahadash    schedule 27.10.2013    source источник

Ответы (1)


arrow_upward
1
arrow_downward

Я думаю, это сработает:

var referenceBack2 = source.Zip(source.Skip(1), (a, b) => a)
person Matthew Finlay    schedule 27.10.2013