Searched refs:duration_sub (Results 1 – 1 of 1) sorted by relevance
224 composite_subscription duration_sub; in on_next() local225 auto ssub = state->source_lifetime.add(duration_sub); in on_next()238 duration_sub.add(robs.subscribe( in on_next()