Call query.close() before awaiting interrupt/return to ensure the stream is properly torn down on session close and query restart.
Call query.close() before awaiting interrupt/return to ensure the stream is properly torn down on session close and query restart.