Searched refs:selectedCollection (Results 1 – 4 of 4) sorted by relevance
57 auto selectedCollection = on_exception( in on_subscribe() local60 if (selectedCollection.empty()) { in on_subscribe()64 selectedCollection->subscribe(o); in on_subscribe()
98 auto selectedCollection = on_exception( in on_subscribe() local101 if (selectedCollection.empty()) { in on_subscribe()105 selectedCollection->subscribe(state->out); in on_subscribe()
151 auto selectedCollection = on_exception( in on_subscribe() local154 if (selectedCollection.empty()) { in on_subscribe()169 [&](){return state->coordinator.in(selectedCollection.get());}, in on_subscribe()
186 auto selectedCollection = state->selectCollection(st); in on_subscribe() local187 auto selectedSource = state->coordinator.in(selectedCollection); in on_subscribe()