{"action":"created","issue":{"url":"https://api.github.com/repos/ReactiveX/RxJava/issues/3064","labels_url":"https://api.github.com/repos/ReactiveX/RxJava/issues/3064/labels{/name}","comments_url":"https://api.github.com/repos/ReactiveX/RxJava/issues/3064/comments","events_url":"https://api.github.com/repos/ReactiveX/RxJava/issues/3064/events","html_url":"https://github.com/ReactiveX/RxJava/issues/3064","id":93034790,"number":3064,"title":"API to clear MultiSourceProducer's buffer/cache when using CombineLatest","user":{"login":"tongc","id":1810275,"avatar_url":"https://avatars.githubusercontent.com/u/1810275?v=3","gravatar_id":"","url":"https://api.github.com/users/tongc","html_url":"https://github.com/tongc","followers_url":"https://api.github.com/users/tongc/followers","following_url":"https://api.github.com/users/tongc/following{/other_user}","gists_url":"https://api.github.com/users/tongc/gists{/gist_id}","starred_url":"https://api.github.com/users/tongc/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/tongc/subscriptions","organizations_url":"https://api.github.com/users/tongc/orgs","repos_url":"https://api.github.com/users/tongc/repos","events_url":"https://api.github.com/users/tongc/events{/privacy}","received_events_url":"https://api.github.com/users/tongc/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":3,"created_at":"2015-07-04T17:59:58Z","updated_at":"2015-07-05T11:50:55Z","closed_at":null,"body":"Based on the nice diagram from official documentation, combineLatest http://reactivex.io/documentation/operators/combinelatest.html\r\n\r\nI wonder if there is a way, say when I received \"C\" from the second Observable, I would like to clear the states inside both first and second Observables. So that when \"D\" arrives from second Observable, it will no longer combine with \"2\" from the first Observable but wait until \"3\" arrives.\r\n\r\nThis is useful in the case like, there is no data after the business day is finished (say 9 to 5, so 16 hours quiet period). So without re-subscribing and re-initializing, it would be nice to clear the state so that the data coming from next business day will not be combined with old data."},"comment":{"url":"https://api.github.com/repos/ReactiveX/RxJava/issues/comments/118615238","html_url":"https://github.com/ReactiveX/RxJava/issues/3064#issuecomment-118615238","issue_url":"https://api.github.com/repos/ReactiveX/RxJava/issues/3064","id":118615238,"user":{"login":"davidmoten","id":318187,"avatar_url":"https://avatars.githubusercontent.com/u/318187?v=3","gravatar_id":"","url":"https://api.github.com/users/davidmoten","html_url":"https://github.com/davidmoten","followers_url":"https://api.github.com/users/davidmoten/followers","following_url":"https://api.github.com/users/davidmoten/following{/other_user}","gists_url":"https://api.github.com/users/davidmoten/gists{/gist_id}","starred_url":"https://api.github.com/users/davidmoten/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/davidmoten/subscriptions","organizations_url":"https://api.github.com/users/davidmoten/orgs","repos_url":"https://api.github.com/users/davidmoten/repos","events_url":"https://api.github.com/users/davidmoten/events{/privacy}","received_events_url":"https://api.github.com/users/davidmoten/received_events","type":"User","site_admin":false},"created_at":"2015-07-05T11:50:55Z","updated_at":"2015-07-05T11:50:55Z","body":">But a new field will be introduced\r\n\r\nDoesn't introduce a new field in your class necessarily because you just wrap your object with `Timestamped` by calling `observable.timestamp()`. \r\n\r\n>a burden of when every message is received\r\n\r\nSure, that's your call to say if it's significant, benchmarks might be handy to do\r\n\r\n>in my case the only occasion that the message might be omitted is that if the first Observable never emitted any message when the day finishes but not if the timestamp is somehow wrong during the day).\r\n\r\nSorry I don't follow this bit.\r\n\r\nYou could also get a reset by using `retry`. Get the stream to complete at the end of the day and chain it with `.retry()`.\r\n\r\n\r\n\r\n\r\n\r\n"}}