File tree Expand file tree Collapse file tree
app/src/main/java/org/schabi/newpipe/player/playqueue Expand file tree Collapse file tree Original file line number Diff line number Diff line change 2323import io .reactivex .rxjava3 .android .schedulers .AndroidSchedulers ;
2424import io .reactivex .rxjava3 .core .BackpressureStrategy ;
2525import io .reactivex .rxjava3 .core .Flowable ;
26- import io .reactivex .rxjava3 .subjects .BehaviorSubject ;
26+ import io .reactivex .rxjava3 .subjects .PublishSubject ;
2727
2828/**
2929 * PlayQueue is responsible for keeping track of a list of streams and the index of
@@ -46,7 +46,7 @@ public abstract class PlayQueue implements Serializable {
4646 private List <PlayQueueItem > backup ;
4747 private List <PlayQueueItem > streams ;
4848
49- private transient BehaviorSubject <PlayQueueEvent > eventBroadcast ;
49+ private transient PublishSubject <PlayQueueEvent > eventBroadcast ;
5050 private transient Flowable <PlayQueueEvent > broadcastReceiver ;
5151 private transient boolean disposed = false ;
5252
@@ -71,7 +71,7 @@ public abstract class PlayQueue implements Serializable {
7171 * </p>
7272 */
7373 public void init () {
74- eventBroadcast = BehaviorSubject .create ();
74+ eventBroadcast = PublishSubject .create ();
7575
7676 broadcastReceiver = eventBroadcast .toFlowable (BackpressureStrategy .BUFFER )
7777 .observeOn (AndroidSchedulers .mainThread ())
You can’t perform that action at this time.
0 commit comments