sampleFixedSize()

Perform a fixed-size sampling over the input stream.

Implementation Notes

This uses the reservoir method internally and guarantees for that streams that are at least sampleSize in length, there will be exactly sampleSize elements in the output stream. Elements will be emitted in the order in which they are encountered. This implementation reads the entire stream before emitting any results, making it inappropriate for infinite streams.

Signature

sampleFixedSize(int sampleSize)

sampleSize - A positive number of elements to sample from the stream, randomly

Examples

Get a fixed number of elements from the stream, randomly

Stream
    .of("A", "B", "C", "D", "E")
    .gather(Gatherers4j.sampleFixedSize(2))
    .toList();

// Possibly: ["A", "D"]
// Answer will be different every time