package com.marverenic.music.player.transaction;

import android.support.annotation.NonNull;

public final class IncomingTransaction<T> {

    private Aggregator<T> mAggregator;

    private String mTransactionId;
    private int mOffset;
    private int mSize;
    private T mAggregate;

    @SuppressWarnings("unchecked")
    IncomingTransaction(TransactionToken token, T emptyAggregate, Aggregator<T> aggregator) {
        if (token == null) {
            throw new IllegalArgumentException("Token cannot be null");
        } else if (aggregator == null) {
            throw new IllegalArgumentException("Aggregator cannot be null");
        }

        mTransactionId = token.getTransactionId();
        mSize = token.getSize();
        mAggregator = aggregator;
        mAggregate = emptyAggregate;
    }

    public void receive(@NonNull TransactionChunk<T> chunk) {
        if (!mTransactionId.equals(chunk.getTransactionId())) {
            throw new IllegalArgumentException("Chunk contains data from a different transaction");
        }

        if (chunk.getOffset() > mOffset) {
            throw new IllegalArgumentException("Chunk arrived early");
        } else if (chunk.getOffset() < mOffset) {
            throw new IllegalArgumentException("Duplicate chunk arrived");
        } else if (mOffset + chunk.getSize() > mSize) {
            throw new IllegalArgumentException("Chunk has too much data");
        }

        mAggregate = mAggregator.aggregate(mAggregate, chunk.getData(), chunk.getOffset());
        mOffset += chunk.getSize();
    }

    public T getData() {
        if (mOffset < mSize) {
            throw new IllegalStateException("Not all data has been received");
        }
        return mAggregate;
    }

    interface Aggregator<T> {
        T aggregate(T aggregate, T toAppend, int offset);
    }

}

@@ -286,43 +286,8 @@
 e;%0A%0A
-    @SuppressWarnings(%22unchecked%22)%0A
     

Remove unnecessary suppression