Searched refs:streamGraphInterface (Results 1 – 2 of 2) sorted by relevance
33 StreamGraphInterface* streamGraphInterface) : in SingleStreamObserver() argument36 mStreamGraphInterface(streamGraphInterface) {} in SingleStreamObserver()127 StreamGraphInterface* streamGraphInterface) : in StreamSetObserver() argument128 mClientConfig(clientConfig), mStreamGraphInterface(streamGraphInterface) {} in StreamSetObserver()163 mGraphTerminationThread = std::thread([streamGraphInterface(mStreamGraphInterface)]() { in stopObservingStreams()164 streamGraphInterface->dispatchGraphTerminationMessage(Status::SUCCESS, ""); in stopObservingStreams()189 mGraphTerminationThread = std::thread([streamGraphInterface(mStreamGraphInterface)]() { in reportStreamClosed()190 streamGraphInterface->dispatchGraphTerminationMessage(Status::SUCCESS, ""); in reportStreamClosed()
63 StreamGraphInterface* streamGraphInterface);84 StreamGraphInterface* streamGraphInterface);