Searched refs:sinkInner (Results 1 – 7 of 7) sorted by relevance
150 auto sinkInner = make_subscriber<collection_value_type>( in on_subscribe() local169 auto selectedSinkInner = state->coordinator.out(sinkInner); in on_subscribe()
168 auto sinkInner = make_subscriber<value_type>( in on_subscribe() local187 auto selectedSinkInner = state->coordinator.out(sinkInner); in on_subscribe()
162 auto sinkInner = make_subscriber<value_type>( in on_subscribe() local191 auto selectedSinkInner = state->coordinator.out(sinkInner); in on_subscribe()
170 auto sinkInner = make_subscriber<value_type>( in on_subscribe() local195 auto selectedSinkInner = state->coordinator.out(sinkInner); in on_subscribe()
138 auto sinkInner = make_subscriber<value_type>( in on_subscribe() local162 [&](){return state->coordinator.out(sinkInner);}, in on_subscribe()
192 auto sinkInner = make_subscriber<collection_value_type>( in on_subscribe() local212 auto selectedSinkInner = state->coordinator.out(sinkInner); in on_subscribe()
177 auto sinkInner = make_subscriber<collection_value_type>( in on_subscribe() local202 [&](){return state->coordinator.out(sinkInner);}, in on_subscribe()