Implement async streaming history