IoUtils.safeShutdownReads(remoteConnection.getChannel());

    protected void closeAction() throws IOException {
        sendCloseRequest();
        remoteConnection.shutdownWrites();
        IoUtils.safeShutdownReads(remoteConnection.getChannel());
        // now these guys can't send useless messages
        closePendingChannels();
        closeAllChannels();
        remoteConnection.getRemoteConnectionProvider().removeConnectionHandler(this);
    }

    public void closeAsync() {
        ...
        if (first) try {
            closeAction();
        } catch (IOException e) {
            log.tracef(e, "Close of %s failed", this);
            final Map<Key, CloseHandler<? super T>> closeHandlers;
            synchronized (closeLock) {
                state = State.CLOSED;
                closeHandlers = this.closeHandlers;
                this.closeHandlers = null;
                closeLock.notifyAll();
            }
            if (closeHandlers != null) {
                for (final CloseHandler<? super T> handler : closeHandlers.values()) {
                    runCloseTask(new CloseHandlerTask(handler, e));
                }
            }
        } catch (Throwable t) {
            log.errorf(t, "Close action for %s failed to execute (resource may be left in an indeterminate state)", this);
            // -- here non async version marks resource as closed too --
        }
    }