}
                }
            });
        }

        void stop() {
            maybeClosed();
        }

        private void maybeClosed() {
            // This can be invoked from the reader thread or some other thread that is attempting to shut the client down.
            synchronized (lock) {
                if (!closed) {