ObjectSampler.java

  1. /*
  2.  * Licensed to the Apache Software Foundation (ASF) under one or more
  3.  * contributor license agreements.  See the NOTICE file distributed with
  4.  * this work for additional information regarding copyright ownership.
  5.  * The ASF licenses this file to You under the Apache License, Version 2.0
  6.  * (the "License"); you may not use this file except in compliance with
  7.  * the License.  You may obtain a copy of the License at
  8.  *
  9.  *      http://www.apache.org/licenses/LICENSE-2.0
  10.  *
  11.  * Unless required by applicable law or agreed to in writing, software
  12.  * distributed under the License is distributed on an "AS IS" BASIS,
  13.  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14.  * See the License for the specific language governing permissions and
  15.  * limitations under the License.
  16.  */

  17. package org.apache.commons.rng.sampling;

  18. import java.util.stream.Stream;

  19. /**
  20.  * Sampler that generates values of a specified type.
  21.  *
  22.  * @param <T> Type of the sample.
  23.  * @since 1.4
  24.  */
  25. public interface ObjectSampler<T> {
  26.     /**
  27.      * Create an object sample.
  28.      *
  29.      * @return a sample.
  30.      */
  31.     T sample();

  32.     /**
  33.      * Returns an effectively unlimited stream of object sample values.
  34.      *
  35.      * <p>The default implementation produces a sequential stream that repeatedly
  36.      * calls {@link #sample sample}().
  37.      *
  38.      * @return a stream of object values.
  39.      * @since 1.5
  40.      */
  41.     default Stream<T> samples() {
  42.         return Stream.generate(this::sample).sequential();
  43.     }

  44.     /**
  45.      * Returns a stream producing the given {@code streamSize} number of object
  46.      * sample values.
  47.      *
  48.      * <p>The default implementation produces a sequential stream that repeatedly
  49.      * calls {@link #sample sample}(); the stream is limited to the given {@code streamSize}.
  50.      *
  51.      * @param streamSize Number of values to generate.
  52.      * @return a stream of object values.
  53.      * @since 1.5
  54.      */
  55.     default Stream<T> samples(long streamSize) {
  56.         return samples().limit(streamSize);
  57.     }
  58. }