@@ -2489,7 +2489,25 @@ public final static <T> Observable<Observable<T>> parallelMerge(Observable<Obser
2489
2489
}
2490
2490
2491
2491
/**
2492
- * Pivot GroupedObservable streams without serializing/synchronizing to a single stream first.
2492
+ * Pivot GroupedObservable streams without serializing/synchronizing to a single stream first.
2493
+ *
2494
+ * For example an Observable such as this =>
2495
+ *
2496
+ * Observable<GroupedObservable<String, GroupedObservable<Boolean, Integer>>>:
2497
+ *
2498
+ * o1.odd: 1, 3, 5, 7, 9 on Thread 1
2499
+ * o1.even: 2, 4, 6, 8, 10 on Thread 1
2500
+ * o2.odd: 11, 13, 15, 17, 19 on Thread 2
2501
+ * o2.even: 12, 14, 16, 18, 20 on Thread 2
2502
+ *
2503
+ * is pivoted to become this =>
2504
+ *
2505
+ * Observable<GroupedObservable<Boolean, GroupedObservable<String, Integer>>>:
2506
+ *
2507
+ * odd.o1: 1, 3, 5, 7, 9 on Thread 1
2508
+ * odd.o2: 11, 13, 15, 17, 19 on Thread 2
2509
+ * even.o1: 2, 4, 6, 8, 10 on Thread 1
2510
+ * even.o2: 12, 14, 16, 18, 20 on Thread 2
2493
2511
*
2494
2512
* @param groups
2495
2513
* @return
0 commit comments