fix stream on_data