private SqlDataReader RunExecuteReaderTds( CommandBehavior cmdBehavior, RunBehavior runBehavior, bool returnStream, bool async, int timeout, out Task task, bool asyncWrite, bool inRetry, SqlDataReader ds=null, bool describeParameterEncryptionRequest = false) {

            Debug.Assert(!asyncWrite || async, "AsyncWrite should be always accompanied by Async");



            if (ds == null && returnStream) {

                ds = new SqlDataReader(this, cmdBehavior);

            }



            Task reconnectTask = _activeConnection.ValidateAndReconnect(null, timeout);



            if (reconnectTask != null) {

                long reconnectionStart = ADP.TimerCurrent();

                if (async) {                    

                    TaskCompletionSource<object> completion = new TaskCompletionSource<object>();

                    _activeConnection.RegisterWaitingForReconnect(completion.Task);

                    _reconnectionCompletionSource = completion;

                    CancellationTokenSource timeoutCTS = new CancellationTokenSource();

                    AsyncHelper.SetTimeoutException(completion, timeout, SQL.CR_ReconnectTimeout, timeoutCTS.Token);

                    AsyncHelper.ContinueTask(reconnectTask, completion,

                        () => {

                            if (completion.Task.IsCompleted) {

                                return;

                            }

                            Interlocked.CompareExchange(ref _reconnectionCompletionSource, null, completion);

                            timeoutCTS.Cancel();

                            Task subTask;                            

                            RunExecuteReaderTds(cmdBehavior, runBehavior, returnStream, async, TdsParserStaticMethods.GetRemainingTimeout(timeout, reconnectionStart), out subTask, asyncWrite, inRetry, ds);

                            if (subTask == null) {

                                completion.SetResult(null);

                            }

                            else {

                                AsyncHelper.ContinueTask(subTask, completion, () => completion.SetResult(null));

                            }

                        }, connectionToAbort: _activeConnection);

                    task = completion.Task;

                    return ds;

                }

                else {

                    AsyncHelper.WaitForCompletion(reconnectTask, timeout, () => { throw SQL.CR_ReconnectTimeout(); });

                    timeout = TdsParserStaticMethods.GetRemainingTimeout(timeout, reconnectionStart);

                }

            }