view release on metacpan or  search on metacpan

lib/Async/Redis/AutoPipeline.pm  view on Meta::CPAN

                        'fail',
                    );
                }
                await $redis->_send($buffer);
            })->();
        });

        $redis->_ensure_reader;
    })->();

    # Transport failure on submit cascades to every future that wasn't
    # already failed by _reader_fatal.
    $submit->on_fail(sub {
        my ($err) = @_;
        for my $f (@futures) {
            $f->fail($err) unless $f->is_ready;
        }
    });

    # Ownership: the client's Future::Selector (_tasks) owns this submit
    # task. Any caller currently awaiting inside run_until_ready sees a