Searched refs:subj_id (Results 1 – 1 of 1) sorted by relevance
93 , subj_id(0) in window_with_time_or_count_subscriber_values()101 mutable int subj_id; member110 auto new_id = state->subj_id; in window_with_time_or_count_observer()146 if (id != state->subj_id) in release_window()153 auto new_id = ++state->subj_id; in release_window()174 release_window(localState->subj_id, localState->worker.now(), localState)(self); in on_next()