I like the API @agramfort propses. The logic is simplification. Instead of a thread that concurrently sends raw buffers to RtEpochs using callbacks here we just send data once and consume them subsequently. So no real waiting, only API interfacing. Makes sense?