modify astream callback interfaces