bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerHandle.java [1051:1077]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                .whenCompleteAsync(new FutureEventListener<LedgerEntries>() {
                    @Override
                    public void onSuccess(LedgerEntries entries) {
                        cb.readComplete(
                            Code.OK,
                            LedgerHandle.this,
                            IteratorUtils.asEnumeration(
                                Iterators.transform(entries.iterator(), le -> {
                                    LedgerEntry entry = new LedgerEntry((LedgerEntryImpl) le);
                                    le.close();
                                    return entry;
                                })),
                            ctx);
                    }

                    @Override
                    public void onFailure(Throwable cause) {
                        if (cause instanceof BKException) {
                            BKException bke = (BKException) cause;
                            cb.readComplete(bke.getCode(), LedgerHandle.this, null, ctx);
                        } else {
                            cb.readComplete(Code.UnexpectedConditionException, LedgerHandle.this, null, ctx);
                        }
                    }
                    }, clientCtx.getMainWorkerPool().chooseThread(ledgerId));
        } else {
            cb.readComplete(Code.ClientClosedException, LedgerHandle.this, null, ctx);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerHandle.java [1085:1111]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                    .whenCompleteAsync(new FutureEventListener<LedgerEntries>() {
                        @Override
                        public void onSuccess(LedgerEntries entries) {
                            cb.readComplete(
                                    Code.OK,
                                    LedgerHandle.this,
                                    IteratorUtils.asEnumeration(
                                            Iterators.transform(entries.iterator(), le -> {
                                                LedgerEntry entry = new LedgerEntry((LedgerEntryImpl) le);
                                                le.close();
                                                return entry;
                                            })),
                                    ctx);
                        }

                        @Override
                        public void onFailure(Throwable cause) {
                            if (cause instanceof BKException) {
                                BKException bke = (BKException) cause;
                                cb.readComplete(bke.getCode(), LedgerHandle.this, null, ctx);
                            } else {
                                cb.readComplete(Code.UnexpectedConditionException, LedgerHandle.this, null, ctx);
                            }
                        }
                    }, clientCtx.getMainWorkerPool().chooseThread(ledgerId));
        } else {
            cb.readComplete(Code.ClientClosedException, LedgerHandle.this, null, ctx);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -