implement job streaming