}
                final BulkResponse response = bulkRequest.execute().actionGet(30_000L);
                if (response.hasFailures()) {
                    logger.warn("Failed to write log notifications: {}", response.buildFailureMessage());
                }
            }
        } catch (final Exception e) {

            }
        }

        final BulkResponse response = bulkRequestBuilder.execute().actionGet(settings.getBulkTimeout());
        final SuggestWriterResult result = new SuggestWriterResult();
        if (response.hasFailures()) {
            for (final BulkItemResponse bulkItemResponses : response.getItems()) {
                if (bulkItemResponses.isFailed()) {

     */
    protected void flush() {
        if (bulkRequestBuilder != null) {
            final BulkResponse response = bulkRequestBuilder.execute().actionGet(requestTimeout);
            if (response.hasFailures()) {
                logger.warn("Failed to update scores: {}", response.buildFailureMessage());
            }
            bulkRequestBuilder = null;
        }
    }

    /**

                itemMap.put("message", item.getFailureMessage());
            } else {
                itemMap.put("id", item.getId());
            }
            return itemMap;
        }).toList()).status(response.hasFailures() ? Status.FAILED : Status.OK).result());

    }

        assertTrue(result.hasFailure());
        assertEquals(3, result.getFailures().size());
    }

    @Test
    public void test_hasFailure() throws Exception {
        SuggestWriterResult result = new SuggestWriterResult();

        assertFalse(result.hasFailure());

        result.addFailure(new Exception("Test"));

        assertTrue(result.hasFailure());
    }

    @Test

        failures.add(t);
    }

    /**
     * Checks if there are any failures recorded.
     *
     * @return true if there is at least one failure, false otherwise
     */
    public boolean hasFailure() {
        return !failures.isEmpty();
    }

    /**
     * Returns the list of failures.
     *
     * @return a List of Throwable objects representing the failures
     */

        exchange.finishRequest()
      }
    } catch (e: IOException) {
      if (e is ConnectionShutdownException) {
        throw e // No request was sent so there's no response to read.
      }
      if (!exchange.hasFailure) {
        throw e // Don't attempt to read the response; we failed to send the request.
      }
      sendRequestException = e
    }

    try {
      if (responseBuilder == null) {

                final SuggestWriterResult result =
                        suggestWriter.write(client, settings, index, updateItems.toArray(new SuggestItem[updateItems.size()]), false);
                if (result.hasFailure()) {
                    throw new SuggestIndexException(result.getFailures().get(0));
                }
                updateItems.clear();