Implement streaming mode for para_afh.