Searched refs:source_values (Results 1 – 1 of 1) sorted by relevance
103 mutable std::list<source_value_type> source_values; in on_subscribe() member127 if(!state->source_values.empty() && !state->other_values.empty()) { in on_subscribe()128 auto x = std::move(state->source_values.front()); in on_subscribe()129 state->source_values.pop_front(); in on_subscribe()139 if((!state->source_values.empty() && state->other_completed) || in on_subscribe()149 state->out.on_next(state->source_values.empty() && state->other_values.empty()); in on_subscribe()187 auto& values = state->source_values; in on_subscribe()