Handle error when session is terminated/blocked

[chamorin]

Right now the sink will run until the "inactivity" is triggered when a session is terminated. Needs to stop immediately with clear error message