ThrottlingTest.java

@Test
    public void throttlingRxJava() throws Exception {

        Observable<Long> everySecond = Observable.fromIterable(Arrays.asList(1L, 2L, 3L, 4L, 5L, 6L, 7L, 8L, 9L, 10L))
            .map(aLong -> {
                try {
                    Thread.sleep(1_000L);
                } catch (InterruptedException e) {
                    //
                }
                return aLong;
            });

        Observable<Long> everyHundredMillis = Observable.interval(1, TimeUnit.MILLISECONDS);

        everyHundredMillis
            .map(a -> System.nanoTime())
            .zipWith(everySecond, new BiFunction<Long, Long, Tuple2<Long, Long>>() {
                @Override
                public Tuple2<Long, Long> apply(Long aLong, Long aLong2) throws Exception {
                    return Tuples.of(aLong, aLong2);
                }
            })
            .subscribe(aLong -> log.info(aLong + ""));

    }