Make parallel-ware plugins that wait for data to becomes available