@@ -369,7 +369,7 @@ public static Completable merge(Publisher<? extends CompletableConsumable> sourc
369
369
* @throws NullPointerException if sources is null
370
370
* @throws IllegalArgumentException if maxConcurrency is less than 1
371
371
*/
372
- protected static Completable merge0 (Publisher <? extends CompletableConsumable > sources , int maxConcurrency , boolean delayErrors ) {
372
+ private static Completable merge0 (Publisher <? extends CompletableConsumable > sources , int maxConcurrency , boolean delayErrors ) {
373
373
Objects .requireNonNull (sources , "sources is null" );
374
374
if (maxConcurrency < 1 ) {
375
375
throw new IllegalArgumentException ("maxConcurrency > 0 required but it was " + maxConcurrency );
@@ -469,7 +469,7 @@ public static Completable timer(final long delay, final TimeUnit unit, final Sch
469
469
* @param ex the Throwable instance to use as cause, not null (not verified)
470
470
* @return the created NullPointerException
471
471
*/
472
- static NullPointerException toNpe (Throwable ex ) {
472
+ private static NullPointerException toNpe (Throwable ex ) {
473
473
NullPointerException npe = new NullPointerException ("Actually not, but can't pass out an exception otherwise..." );
474
474
npe .initCause (ex );
475
475
return npe ;
@@ -671,7 +671,7 @@ public final Completable doOnError(Consumer<? super Throwable> onError) {
671
671
* @return the new Completable instance
672
672
*/
673
673
@ SchedulerSupport (SchedulerSupport .NONE )
674
- protected final Completable doOnLifecycle (
674
+ private Completable doOnLifecycle (
675
675
final Consumer <? super Disposable > onSubscribe ,
676
676
final Consumer <? super Throwable > onError ,
677
677
final Runnable onComplete ,
@@ -1199,7 +1199,7 @@ public final Completable timeout(long timeout, TimeUnit unit, Scheduler schedule
1199
1199
* @throws NullPointerException if unit or scheduler
1200
1200
*/
1201
1201
@ SchedulerSupport (SchedulerSupport .CUSTOM )
1202
- public final Completable timeout0 (long timeout , TimeUnit unit , Scheduler scheduler , CompletableConsumable other ) {
1202
+ private Completable timeout0 (long timeout , TimeUnit unit , Scheduler scheduler , CompletableConsumable other ) {
1203
1203
Objects .requireNonNull (unit , "unit is null" );
1204
1204
Objects .requireNonNull (scheduler , "scheduler is null" );
1205
1205
return new CompletableTimeout (this , timeout , unit , scheduler , other );
0 commit comments