@@ -4461,7 +4461,7 @@ public static Flowable<Long> timer(long delay, @NonNull TimeUnit unit, @NonNull
4461
4461
4462
4462
/**
4463
4463
* Create a {@code Flowable} by wrapping a {@link Publisher} <em>which has to be implemented according
4464
- * to the <em >Reactive Streams</em > specification by handling backpressure and
4464
+ * to the <b >Reactive Streams</b > specification by handling backpressure and
4465
4465
* cancellation correctly; no safeguards are provided by the {@code Flowable} itself</em>.
4466
4466
* <dl>
4467
4467
* <dt><b>Backpressure:</b></dt>
@@ -10967,7 +10967,7 @@ public final <K, V> Flowable<GroupedFlowable<K, V>> groupBy(@NonNull Function<?
10967
10967
*
10968
10968
* // Emit 1000 items but ensure that the
10969
10969
* // internal map never has more than 3 items in it
10970
- * {@code Flowable}
10970
+ * Flowable
10971
10971
* .range(1, 1000)
10972
10972
* // note that number of keys is 10
10973
10973
* .groupBy(x -> x % 10, x -> x, true, 16, evictingMapFactory)
@@ -16322,8 +16322,8 @@ public final Flowable<T> throttleLast(long intervalDuration, @NonNull TimeUnit u
16322
16322
* Returns a {@code Flowable} that emits only the last item emitted by the source {@link Publisher} during sequential
16323
16323
* time windows of a specified duration, where the duration is governed by a specified {@link Scheduler}.
16324
16324
* <p>
16325
- * This differs from {@link #throttleFirst} in that this ticks along at a scheduled interval whereas
16326
- * {@link # throttleFirst} does not tick, it just tracks the passage of time.
16325
+ * This differs from {@link #throttleFirst(long, TimeUnit, Scheduler) } in that this ticks along at a scheduled interval whereas
16326
+ * {@code throttleFirst} does not tick, it just tracks the passage of time.
16327
16327
* <p>
16328
16328
* <img width="640" height="305" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/throttleLast.s.png" alt="">
16329
16329
* <dl>
0 commit comments