refactor
Create object which waits for something to be available, used when testing async
publish datapoints to topic after writing to disk