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()160 std::thread t([streamGraphInterface(mStreamGraphInterface)]() { in stopObservingStreams()161 streamGraphInterface->dispatchGraphTerminationMessage(Status::SUCCESS, ""); in stopObservingStreams()187 std::thread t([streamGraphInterface(mStreamGraphInterface)]() { in reportStreamClosed()188 streamGraphInterface->dispatchGraphTerminationMessage(Status::SUCCESS, ""); in reportStreamClosed()
63 StreamGraphInterface* streamGraphInterface);82 StreamGraphInterface* streamGraphInterface);