Skip to content

Commit

Permalink
Less silly generics for Loader.
Browse files Browse the repository at this point in the history
-------------
Created by MOE: https://github.com/google/moe
MOE_MIGRATED_REVID=123310694
  • Loading branch information
ojw28 committed Jun 15, 2016
1 parent 1ea149a commit c650ab6
Show file tree
Hide file tree
Showing 7 changed files with 17 additions and 17 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -65,7 +65,7 @@ public interface EventListener {

private final Uri uri;
private final DataSource dataSource;
private final Loader<SingleSampleSource> loader;
private final Loader loader;
private final Format format;
private final long durationUs;
private final TrackGroupArray tracks;
Expand Down Expand Up @@ -99,7 +99,7 @@ public SingleSampleSource(Uri uri, DataSource dataSource, Format format, long du
this.eventHandler = eventHandler;
this.eventListener = eventListener;
this.eventSourceId = eventSourceId;
loader = new Loader<>("Loader:SingleSampleSource", minLoadableRetryCount);
loader = new Loader("Loader:SingleSampleSource", minLoadableRetryCount);
tracks = new TrackGroupArray(new TrackGroup(format));
sampleData = new byte[INITIAL_SAMPLE_SIZE];
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,7 @@
*/
public class ChunkTrackStream implements TrackStream, Loader.Callback<Chunk> {

private final Loader<Chunk> loader;
private final Loader loader;
private final ChunkSource chunkSource;
private final LinkedList<BaseMediaChunk> mediaChunks;
private final List<BaseMediaChunk> readOnlyMediaChunks;
Expand Down Expand Up @@ -76,7 +76,7 @@ public ChunkTrackStream(ChunkSource chunkSource, LoadControl loadControl,
ChunkTrackStreamEventListener eventListener, int eventSourceId, int minLoadableRetryCount) {
this.chunkSource = chunkSource;
this.loadControl = loadControl;
loader = new Loader<>("Loader:ChunkTrackStream", minLoadableRetryCount);
loader = new Loader("Loader:ChunkTrackStream", minLoadableRetryCount);
eventDispatcher = new EventDispatcher(eventHandler, eventListener, eventSourceId);
nextChunkHolder = new ChunkHolder();
mediaChunks = new LinkedList<>();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -69,7 +69,7 @@ public interface UtcTimingCallback {
private final long timingElementElapsedRealtime;
private final UtcTimingCallback callback;

private Loader<UriLoadable<Long>> singleUseLoader;
private Loader singleUseLoader;

/**
* Resolves a {@link UtcTimingElement}.
Expand Down Expand Up @@ -121,7 +121,7 @@ private void resolveDirect() {
}

private void resolveHttp(UriLoadable.Parser<Long> parser) {
singleUseLoader = new Loader<>("Loader:UtcTiming", 0);
singleUseLoader = new Loader("Loader:UtcTiming", 0);
singleUseLoader.startLoading(
new UriLoadable<>(Uri.parse(timingElement.value), dataSource, parser), this);
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -112,7 +112,7 @@ public UnrecognizedInputFormatException(Extractor[] extractors) {
// Lazily initialized default extractor classes in priority order.
private static List<Class<? extends Extractor>> defaultExtractorClasses;

private final Loader<Loadable> loader;
private final Loader loader;
private final ExtractorHolder extractorHolder;
private final Allocator allocator;
private final int requestedBufferSize;
Expand Down Expand Up @@ -233,7 +233,7 @@ public ExtractorSampleSource(Uri uri, DataSource dataSource, Allocator allocator
// Assume on-demand until we know otherwise.
int initialMinRetryCount = minLoadableRetryCount == MIN_RETRY_COUNT_DEFAULT_FOR_MEDIA
? DEFAULT_MIN_LOADABLE_RETRY_COUNT_ON_DEMAND : minLoadableRetryCount;
loader = new Loader<>("Loader:ExtractorSampleSource", initialMinRetryCount);
loader = new Loader("Loader:ExtractorSampleSource", initialMinRetryCount);
extractorHolder = new ExtractorHolder(extractors, this);
pendingResetPositionUs = C.UNSET_TIME_US;
sampleQueues = new DefaultTrackOutput[0];
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,7 @@
private static final int PRIMARY_TYPE_AUDIO = 2;
private static final int PRIMARY_TYPE_VIDEO = 3;

private final Loader<Chunk> loader;
private final Loader loader;
private final HlsChunkSource chunkSource;
private final SparseArray<DefaultTrackOutput> sampleQueues;
private final LinkedList<HlsMediaChunk> mediaChunks;
Expand Down Expand Up @@ -101,7 +101,7 @@ public HlsTrackStreamWrapper(HlsChunkSource chunkSource, LoadControl loadControl
this.chunkSource = chunkSource;
this.loadControl = loadControl;
this.bufferSizeContribution = bufferSizeContribution;
loader = new Loader<>("Loader:HLS", minLoadableRetryCount);
loader = new Loader("Loader:HlsTrackStreamWrapper", minLoadableRetryCount);
eventDispatcher = new EventDispatcher(eventHandler, eventListener, eventSourceId);
nextChunkHolder = new ChunkHolder();
sampleQueues = new SparseArray<>();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@
/**
* Manages the background loading of {@link Loadable}s.
*/
public final class Loader<T extends Loader.Loadable> {
public final class Loader {

/**
* Thrown when an unexpected exception is encountered during loading.
Expand Down Expand Up @@ -121,7 +121,7 @@ public interface Callback<T extends Loadable> {
private final ExecutorService downloadExecutorService;

private int minRetryCount;
private LoadTask currentTask;
private LoadTask<? extends Loadable> currentTask;
private IOException fatalError;

/**
Expand All @@ -143,10 +143,10 @@ public Loader(String threadName, int minRetryCount) {
* @param callback A callback to invoke when the load ends.
* @throws IllegalStateException If the calling thread does not have an associated {@link Looper}.
*/
public void startLoading(T loadable, Callback<T> callback) {
public <T extends Loadable> void startLoading(T loadable, Callback<T> callback) {
Looper looper = Looper.myLooper();
Assertions.checkState(looper != null);
new LoadTask(looper, loadable, callback).start(0);
new LoadTask<>(looper, loadable, callback).start(0);
}

/**
Expand Down Expand Up @@ -204,7 +204,7 @@ public void release() {
}

@SuppressLint("HandlerLeak")
private final class LoadTask extends Handler implements Runnable {
private final class LoadTask<T extends Loadable> extends Handler implements Runnable {

private static final String TAG = "LoadTask";

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -68,7 +68,7 @@ public interface RedirectingManifest {

}

private final Loader<UriLoadable<T>> loader;
private final Loader loader;
private final UriLoadable.Parser<T> parser;
private final DataSource dataSource;
private final Handler eventHandler;
Expand Down Expand Up @@ -106,7 +106,7 @@ public ManifestFetcher(Uri manifestUri, DataSource dataSource, UriLoadable.Parse
this.dataSource = dataSource;
this.eventHandler = eventHandler;
this.eventListener = eventListener;
loader = new Loader<>("Loader:ManifestFetcher", 1);
loader = new Loader("Loader:ManifestFetcher", 1);
}

/**
Expand Down

0 comments on commit c650ab6

Please sign in to comment.