Результат буферизации от Flowable

Question

У меня есть этот код, который захватывает изображения с веб-камеры , 1 изображение в секунду.

Flowable.interval(0, 1, TimeUnit.MILLISECONDS)
            .map(aLong -> {
                BufferedImage bufferedImage = webcam.getImage();
                return bufferedImage;
            }).subscribe(bufferedImage -> {
        if(bufferedImage != null) {
        }
        // Capture 1000 images
    }, error -> {
        System.out.println(error.getMessage());
    });

С помощью Rx Java как я могу сначала сделать буферизацию 300 изображений, а затем передать 300 изображений (вероятно, массив Java) в метод обработки, скажем, processImages(bufferedImageArray); * 1007? *

Answer 1

просто используйте buffer(count) оператор:

Flowable.interval(0, 1, TimeUnit.MILLISECONDS)
            .map(...)
            .buffer(300)
            .subscribe(...)