package rx.broadcast;

import java.util.stream.IntStream;
import java.util.stream.Stream;

final class VectorTimestamp {
    private long[] ids;

    private long[] timestamps;

    VectorTimestamp(final long[] ids, final long[] timestamps) {
        if (ids.length != timestamps.length) {
            throw new IllegalArgumentException("IDs and timestamps must contain the same number of elements");
        }

        this.ids = ids;
        this.timestamps = timestamps;
    }

    Stream<VectorTimestampEntry> stream() {
        return IntStream.range(0, ids.length).mapToObj(idx -> new VectorTimestampEntry(ids[idx], timestamps[idx]));
    }

}

@@ -167,24 +167,88 @@
 imestamps;%0A%0A
+    @SuppressWarnings(%22unused%22)%0A    VectorTimestamp() %7B%0A%0A    %7D%0A%0A
     VectorTi

Add no-args constructor for VectorTimestamp