library/src/main/java/com/kdgregory/aws/utils/kinesis/KinesisWriter.java
/**
     *  Builds the list of send results. Throws if there's a mismatch between
     *  request and response lists, but leaves partial results.
     */
Builds the list of send results. Throws if there's a mismatch between
request and response lists, but leaves partial results.
Builds the list of send results . Throws if there ' s a mismatch between request and response lists but leaves partial results .
private void populateSendResults(List<PutRecordsRequestEntry> requestEntries, List<PutRecordsResultEntry> resultEntries)
    {
        lastSendResults = new ArrayList<SendResult>(requestEntries.size());
        Iterator<PutRecordsRequestEntry> requestItx = requestEntries.iterator();
        Iterator<PutRecordsResultEntry> resultItx = resultEntries.iterator();
        while (requestItx.hasNext())
        {
            if (! resultItx.hasNext())
            {
                throw new IllegalStateException("had fewer result entries than request entries; stream: " + streamName);
            }
            lastSendResults.add(new SendResult(requestItx.next(), resultItx.next()));
        }
        if (resultItx.hasNext())
        {
            throw new IllegalStateException("had more result entries than request entries; stream: " + streamName);
        }
    }
private void populateSendResults ( List < PutRecordsRequestEntry > requestEntries , List < PutRecordsResultEntry > resultEntries ) { lastSendResults = new ArrayList < SendResult > ( requestEntries . size ( ) ) ; Iterator < PutRecordsRequestEntry > requestItx = requestEntries . iterator ( ) ; Iterator < PutRecordsResultEntry > resultItx = resultEntries . iterator ( ) ; while ( requestItx . hasNext ( ) ) { if ( ! resultItx . hasNext ( ) ) { throw new IllegalStateException ( "had fewer result entries than request entries; stream: " + streamName ) ; } lastSendResults . add ( new SendResult ( requestItx . next ( ) , resultItx . next ( ) ) ) ; } if ( resultItx . hasNext ( ) ) { throw new IllegalStateException ( "had more result entries than request entries; stream: " + streamName ) ; } }
Builds the list of send results.
Builds the list of send results .