#5980 made subscribeActual protected (#6052)

Author: sircelsius

src/main/java/io/reactivex/processors/PublishProcessor.java

@@ -92,7 +92,7 @@ public static <T> PublishProcessor<T> create() {
 
 
     @Override
-    public void subscribeActual(Subscriber<? super T> t) {
+    protected void subscribeActual(Subscriber<? super T> t) {
         PublishSubscription<T> ps = new PublishSubscription<T>(t, this);
         t.onSubscribe(ps);
         if (add(ps)) {

src/main/java/io/reactivex/subjects/PublishSubject.java

@@ -131,7 +131,7 @@ public static <T> PublishSubject<T> create() {
 
 
     @Override
-    public void subscribeActual(Observer<? super T> t) {
+    protected void subscribeActual(Observer<? super T> t) {
         PublishDisposable<T> ps = new PublishDisposable<T>(t, this);
         t.onSubscribe(ps);
         if (add(ps)) {