@Override
    protected void process_activate_read ()
    {
        if (!in_active && (state == State.active || state == State.pending)) {
            in_active = true;
            sink.read_activated (this);
        }
    }