Searched refs:sinkSource (Results 1 – 1 of 1) sorted by relevance
169 auto sinkSource = make_subscriber<T>( in on_subscribe() local195 [&](){return state->coordinator.out(sinkSource);}, in on_subscribe()