Reserve this code in case we need to use it to simplify any cases where we need to re-establish the stream on all shards (such as when an unsharded collection becomes sharded) by pushing the retry behavior up to the drivers.