[siemanko]

#programowanie #java #rxjava #reactiveprogramming #rectiveextensions #reactive

Może ktoś pomóc? Czy jest taki operator, który pozwala na buforowanie emitowanych elementów według takiego schematu:
- początek buforowania następuje wtedy kiedy odstęp pomiędzy poszczególnymi emisjami jest mniejszy niż 1 s
- koniec buforowania jest wtedy kiedy nie ma żadnej emisji od 0,5 s

Operator window i buffer mają coś takiego jak opening selector i closing selector, ale nie mam pojęcia jak to działa i czy by tu pomogło. W całych internetach nie mogę znaleźć przykładu jak to działa.

[siemanko]

@siemanko: Ok, sam znalazłem rozwiązanie. Jest nim mianowicie połączenie buffer i debounce.
Więcej tutaj:
http://nerds.weddingpartyapp.com/tech/2015/01/05/debouncedbuffer-used-in-rxbus-example/