feat(distinct): flush
supports ObservableInput
#7081
Merged
flush
supports ObservableInput
#7081