Streaming Response Followed By a Database Write

[mettafore]

Can someone help me with this SO question? I'm using the AsyncIteratorCallbackHandler to get a streaming response. This is working great using chain.arun and yielding one token at a time from the callback handler. However, when I follow it up with a database write the streaming fails the second time I call the FastAPI request. For more details, check this link:
https://stackoverflow.com/questions/76630087/streaming-response-using-langchain-and-fastapi-followed-database-write