[Bug] Stream fetching has not considered re-org situation

[fenghaojiang]

Your code looks neat but I found a problem. Fetching block chain latest stream data can not directly insert to the storage file. Because re-org may happen after a while. See What's a re-org in Alchemy: https://www.alchemy.com/overviews/what-is-a-reorg