Keep an array of the subjects pending disconnection and use the array when deciding whether to fire another reconnection to the Twitter Streaming API.