Provide method for closing all connections
Unwrap exception if needed
Remove unneeded http retriever
Create AsyncHttpRetriever in factory
Share AsyncHttpRetriever with source and producer
Shutdown http retrievers