sjs/media
1
0
Fork 0
mirror of https://github.com/samsonjs/media.git synced 2026-04-02 10:45:51 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Merge pull request #420 from changxiangzhong:fix/cp-missing

Browse source 
PiperOrigin-RevId: 537014587
(cherry picked from commit a739f6062e)
This commit is contained in:
Tofunmi Adigun-Hameed 2023-06-02 09:15:38 +00:00
parent 1238a5f328
commit 568327ff2e
1 changed files with 11 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
libraries/common/src/main/java/androidx/media3/common/util/ListenerSet.java
View file

@ -99,14 +99,20 @@ public final class ListenerSet<T extends @NonNull Object> {
* during one {@link Looper} message queue iteration were handled by the listeners.
*/
public ListenerSet(Looper looper, Clock clock, IterationFinishedEvent<T> iterationFinishedEvent) {
this(/* listeners= */ new CopyOnWriteArraySet<>(), looper, clock, iterationFinishedEvent);
this(
/* listeners= */ new CopyOnWriteArraySet<>(),
looper,
clock,
iterationFinishedEvent,
/* throwsWhenUsingWrongThread= */ true);
}
private ListenerSet(
CopyOnWriteArraySet<ListenerHolder<T>> listeners,
Looper looper,
Clock clock,
IterationFinishedEvent<T> iterationFinishedEvent) {
IterationFinishedEvent<T> iterationFinishedEvent,
boolean throwsWhenUsingWrongThread) {
this.clock = clock;
this.listeners = listeners;
this.iterationFinishedEvent = iterationFinishedEvent;
@ -117,7 +123,7 @@ public final class ListenerSet<T extends @NonNull Object> {
@SuppressWarnings("nullness:methodref.receiver.bound")
HandlerWrapper handler = clock.createHandler(looper, this::handleMessage);
this.handler = handler;
throwsWhenUsingWrongThread = true;
this.throwsWhenUsingWrongThread = throwsWhenUsingWrongThread;
}
/**
@ -149,7 +155,8 @@ public final class ListenerSet<T extends @NonNull Object> {
@CheckResult
public ListenerSet<T> copy(
Looper looper, Clock clock, IterationFinishedEvent<T> iterationFinishedEvent) {
return new ListenerSet<>(listeners, looper, clock, iterationFinishedEvent);
return new ListenerSet<>(
listeners, looper, clock, iterationFinishedEvent, throwsWhenUsingWrongThread);
}
/**