Java 类com.google.android.exoplayer2.util.Predicate 实例源码

项目：transistor 文件：CronetDataSource.java

CronetDataSource(CronetEngine cronetEngine, Executor executor,
    Predicate<String> contentTypePredicate, TransferListener<? super CronetDataSource> listener,
    int connectTimeoutMs, int readTimeoutMs, boolean resetTimeoutOnRedirects, Clock clock,
    RequestProperties defaultRequestProperties, boolean handleSetCookieRequests) {
  this.cronetEngine = Assertions.checkNotNull(cronetEngine);
  this.executor = Assertions.checkNotNull(executor);
  this.contentTypePredicate = contentTypePredicate;
  this.listener = listener;
  this.connectTimeoutMs = connectTimeoutMs;
  this.readTimeoutMs = readTimeoutMs;
  this.resetTimeoutOnRedirects = resetTimeoutOnRedirects;
  this.clock = Assertions.checkNotNull(clock);
  this.defaultRequestProperties = defaultRequestProperties;
  this.handleSetCookieRequests = handleSetCookieRequests;
  requestProperties = new RequestProperties();
  operation = new ConditionVariable();
}

项目：transistor 文件：OkHttpDataSource.java

/**
 * @param callFactory A {@link Call.Factory} (typically an {@link okhttp3.OkHttpClient}) for use
 *     by the source.
 * @param userAgent An optional User-Agent string.
 * @param contentTypePredicate An optional {@link Predicate}. If a content type is rejected by the
 *     predicate then a {@link InvalidContentTypeException} is thrown from
 *     {@link #open(DataSpec)}.
 * @param listener An optional listener.
 * @param cacheControl An optional {@link CacheControl} for setting the Cache-Control header.
 * @param defaultRequestProperties The optional default {@link RequestProperties} to be sent to
 *    the server as HTTP headers on every request.
 */
public OkHttpDataSource(@NonNull Call.Factory callFactory, @Nullable String userAgent,
    @Nullable Predicate<String> contentTypePredicate,
    @Nullable TransferListener<? super OkHttpDataSource> listener,
    @Nullable CacheControl cacheControl, @Nullable RequestProperties defaultRequestProperties) {
  this.callFactory = Assertions.checkNotNull(callFactory);
  this.userAgent = userAgent;
  this.contentTypePredicate = contentTypePredicate;
  this.listener = listener;
  this.cacheControl = cacheControl;
  this.defaultRequestProperties = defaultRequestProperties;
  this.requestProperties = new RequestProperties();
}

项目：Exoplayer2Radio 文件：IcyDataSource.java

public IcyDataSource(String userAgent, Predicate<String> contentTypePredicate, PlayerCallback playerCallback) {
    super(userAgent, contentTypePredicate);
    this.playerCallback = playerCallback;
}

项目：transistor 文件：IcyDataSource.java

public IcyDataSource(String userAgent, Predicate<String> contentTypePredicate, PlayerCallback playerCallback) {
    super(userAgent, contentTypePredicate);
    this.playerCallback = playerCallback;
}

项目：Phoenix-for-VK 文件：CustomHttpDataSource.java

/**
 * @param userAgent            The User-Agent string that should be used.
 * @param contentTypePredicate An optional {@link Predicate}. If a content type is rejected by the
 *                             predicate then a {@link InvalidContentTypeException} is thrown from
 *                             {@link #open(DataSpec)}.
 * @param listener             An optional listener.
 * @param connectTimeoutMillis The connection timeout, in milliseconds. A timeout of zero is
 *                             interpreted as an infinite timeout.
 * @param readTimeoutMillis    The read timeout, in milliseconds. A timeout of zero is interpreted
 *                             as an infinite timeout.
 */
public CustomHttpDataSource(String userAgent, Predicate<String> contentTypePredicate,
                            TransferListener<? super CustomHttpDataSource> listener, int connectTimeoutMillis,
                            int readTimeoutMillis, Proxy proxy) {
    this(userAgent, contentTypePredicate, listener, connectTimeoutMillis, readTimeoutMillis, false,
            null, proxy);
}

项目：Phoenix-for-VK 文件：CustomHttpDataSource.java

/**
 * @param userAgent                   The User-Agent string that should be used.
 * @param contentTypePredicate        An optional {@link Predicate}. If a content type is rejected by the
 *                                    predicate then a {@link InvalidContentTypeException} is thrown from
 *                                    {@link #open(DataSpec)}.
 * @param listener                    An optional listener.
 * @param connectTimeoutMillis        The connection timeout, in milliseconds. A timeout of zero is
 *                                    interpreted as an infinite timeout. Pass {@link #DEFAULT_CONNECT_TIMEOUT_MILLIS} to use
 *                                    the default value.
 * @param readTimeoutMillis           The read timeout, in milliseconds. A timeout of zero is interpreted
 *                                    as an infinite timeout. Pass {@link #DEFAULT_READ_TIMEOUT_MILLIS} to use the default value.
 * @param allowCrossProtocolRedirects Whether cross-protocol redirects (i.e. redirects from HTTP
 *                                    to HTTPS and vice versa) are enabled.
 * @param defaultRequestProperties    The default request properties to be sent to the server as
 *                                    HTTP headers or {@code null} if not required.
 */
public CustomHttpDataSource(String userAgent, Predicate<String> contentTypePredicate,
                            TransferListener<? super CustomHttpDataSource> listener, int connectTimeoutMillis,
                            int readTimeoutMillis, boolean allowCrossProtocolRedirects,
                            RequestProperties defaultRequestProperties, Proxy proxy) {
    this.userAgent = Assertions.checkNotEmpty(userAgent);
    this.contentTypePredicate = contentTypePredicate;
    this.listener = listener;
    this.requestProperties = new RequestProperties();
    this.connectTimeoutMillis = connectTimeoutMillis;
    this.readTimeoutMillis = readTimeoutMillis;
    this.allowCrossProtocolRedirects = allowCrossProtocolRedirects;
    this.defaultRequestProperties = defaultRequestProperties;
    this.proxy = proxy;
}

项目：Exoplayer2Radio 文件：DefaultHttpDataSource.java

/**
 * @param userAgent The User-Agent string that should be used.
 * @param contentTypePredicate An optional {@link Predicate}. If a content type is rejected by the
 *     predicate then a {@link HttpDataSource.InvalidContentTypeException} is thrown from
 *     {@link #open(DataSpec)}.
 * @param listener An optional listener.
 * @param connectTimeoutMillis The connection timeout, in milliseconds. A timeout of zero is
 *     interpreted as an infinite timeout.
 * @param readTimeoutMillis The read timeout, in milliseconds. A timeout of zero is interpreted
 *     as an infinite timeout.
 */
public DefaultHttpDataSource(String userAgent, Predicate<String> contentTypePredicate,
    TransferListener<? super DefaultHttpDataSource> listener, int connectTimeoutMillis,
    int readTimeoutMillis) {
  this(userAgent, contentTypePredicate, listener, connectTimeoutMillis, readTimeoutMillis, false,
      null);
}

项目：Exoplayer2Radio 文件：DefaultHttpDataSource.java

/**
 * @param userAgent The User-Agent string that should be used.
 * @param contentTypePredicate An optional {@link Predicate}. If a content type is rejected by the
 *     predicate then a {@link HttpDataSource.InvalidContentTypeException} is thrown from
 *     {@link #open(DataSpec)}.
 * @param listener An optional listener.
 * @param connectTimeoutMillis The connection timeout, in milliseconds. A timeout of zero is
 *     interpreted as an infinite timeout. Pass {@link #DEFAULT_CONNECT_TIMEOUT_MILLIS} to use
 *     the default value.
 * @param readTimeoutMillis The read timeout, in milliseconds. A timeout of zero is interpreted
 *     as an infinite timeout. Pass {@link #DEFAULT_READ_TIMEOUT_MILLIS} to use the default value.
 * @param allowCrossProtocolRedirects Whether cross-protocol redirects (i.e. redirects from HTTP
 *     to HTTPS and vice versa) are enabled.
 * @param defaultRequestProperties The default request properties to be sent to the server as
 *     HTTP headers or {@code null} if not required.
 */
public DefaultHttpDataSource(String userAgent, Predicate<String> contentTypePredicate,
    TransferListener<? super DefaultHttpDataSource> listener, int connectTimeoutMillis,
    int readTimeoutMillis, boolean allowCrossProtocolRedirects,
    RequestProperties defaultRequestProperties) {
  this.userAgent = Assertions.checkNotEmpty(userAgent);
  this.contentTypePredicate = contentTypePredicate;
  this.listener = listener;
  this.requestProperties = new RequestProperties();
  this.connectTimeoutMillis = connectTimeoutMillis;
  this.readTimeoutMillis = readTimeoutMillis;
  this.allowCrossProtocolRedirects = allowCrossProtocolRedirects;
  this.defaultRequestProperties = defaultRequestProperties;
}

项目：K-Sonic 文件：DefaultHttpDataSource.java

/**
 * @param userAgent The User-Agent string that should be used.
 * @param contentTypePredicate An optional {@link Predicate}. If a content type is rejected by the
 *     predicate then a {@link HttpDataSource.InvalidContentTypeException} is thrown from
 *     {@link #open(DataSpec)}.
 * @param listener An optional listener.
 * @param connectTimeoutMillis The connection timeout, in milliseconds. A timeout of zero is
 *     interpreted as an infinite timeout.
 * @param readTimeoutMillis The read timeout, in milliseconds. A timeout of zero is interpreted
 *     as an infinite timeout.
 */
public DefaultHttpDataSource(String userAgent, Predicate<String> contentTypePredicate,
    TransferListener<? super DefaultHttpDataSource> listener, int connectTimeoutMillis,
    int readTimeoutMillis) {
  this(userAgent, contentTypePredicate, listener, connectTimeoutMillis, readTimeoutMillis, false,
      null);
}

项目：K-Sonic 文件：DefaultHttpDataSource.java

/**
 * @param userAgent The User-Agent string that should be used.
 * @param contentTypePredicate An optional {@link Predicate}. If a content type is rejected by the
 *     predicate then a {@link HttpDataSource.InvalidContentTypeException} is thrown from
 *     {@link #open(DataSpec)}.
 * @param listener An optional listener.
 * @param connectTimeoutMillis The connection timeout, in milliseconds. A timeout of zero is
 *     interpreted as an infinite timeout. Pass {@link #DEFAULT_CONNECT_TIMEOUT_MILLIS} to use
 *     the default value.
 * @param readTimeoutMillis The read timeout, in milliseconds. A timeout of zero is interpreted
 *     as an infinite timeout. Pass {@link #DEFAULT_READ_TIMEOUT_MILLIS} to use the default value.
 * @param allowCrossProtocolRedirects Whether cross-protocol redirects (i.e. redirects from HTTP
 *     to HTTPS and vice versa) are enabled.
 * @param defaultRequestProperties The default request properties to be sent to the server as
 *     HTTP headers or {@code null} if not required.
 */
public DefaultHttpDataSource(String userAgent, Predicate<String> contentTypePredicate,
    TransferListener<? super DefaultHttpDataSource> listener, int connectTimeoutMillis,
    int readTimeoutMillis, boolean allowCrossProtocolRedirects,
    RequestProperties defaultRequestProperties) {
  this.userAgent = Assertions.checkNotEmpty(userAgent);
  this.contentTypePredicate = contentTypePredicate;
  this.listener = listener;
  this.requestProperties = new RequestProperties();
  this.connectTimeoutMillis = connectTimeoutMillis;
  this.readTimeoutMillis = readTimeoutMillis;
  this.allowCrossProtocolRedirects = allowCrossProtocolRedirects;
  this.defaultRequestProperties = defaultRequestProperties;
}

项目：videoPickPlayer 文件：DefaultHttpDataSource.java

/**
 * @param userAgent The User-Agent string that should be used.
 * @param contentTypePredicate An optional {@link Predicate}. If a content type is rejected by the
 *     predicate then a {@link HttpDataSource.InvalidContentTypeException} is thrown from
 *     {@link #open(DataSpec)}.
 * @param listener An optional listener.
 * @param connectTimeoutMillis The connection timeout, in milliseconds. A timeout of zero is
 *     interpreted as an infinite timeout. Pass {@link #DEFAULT_CONNECT_TIMEOUT_MILLIS} to use
 *     the default value.
 * @param readTimeoutMillis The read timeout, in milliseconds. A timeout of zero is interpreted
 *     as an infinite timeout. Pass {@link #DEFAULT_READ_TIMEOUT_MILLIS} to use the default value.
 * @param allowCrossProtocolRedirects Whether cross-protocol redirects (i.e. redirects from HTTP
 *     to HTTPS and vice versa) are enabled.
 */
public DefaultHttpDataSource(String userAgent, Predicate<String> contentTypePredicate,
    TransferListener<? super DefaultHttpDataSource> listener, int connectTimeoutMillis,
    int readTimeoutMillis, boolean allowCrossProtocolRedirects) {
  this.userAgent = Assertions.checkNotEmpty(userAgent);
  this.contentTypePredicate = contentTypePredicate;
  this.listener = listener;
  this.requestProperties = new HashMap<>();
  this.connectTimeoutMillis = connectTimeoutMillis;
  this.readTimeoutMillis = readTimeoutMillis;
  this.allowCrossProtocolRedirects = allowCrossProtocolRedirects;
}

项目：transistor 文件：CronetDataSourceFactory.java

/**
 * Constructs a CronetDataSourceFactory.
 * <p>
 * If the {@link CronetEngineWrapper} fails to provide a {@link CronetEngine}, the provided
 * fallback {@link HttpDataSource.Factory} will be used instead.
 *
 * Sets {@link CronetDataSource#DEFAULT_CONNECT_TIMEOUT_MILLIS} as the connection timeout, {@link
 * CronetDataSource#DEFAULT_READ_TIMEOUT_MILLIS} as the read timeout and disables
 * cross-protocol redirects.
 *
 * @param cronetEngineWrapper A {@link CronetEngineWrapper}.
 * @param executor The {@link java.util.concurrent.Executor} that will perform the requests.
 * @param contentTypePredicate An optional {@link Predicate}. If a content type is rejected by the
 *     predicate then an {@link InvalidContentTypeException} is thrown from
 *     {@link CronetDataSource#open}.
 * @param transferListener An optional listener.
 * @param fallbackFactory A {@link HttpDataSource.Factory} which is used as a fallback in case
 *     no suitable CronetEngine can be build.
 */
public CronetDataSourceFactory(CronetEngineWrapper cronetEngineWrapper,
    Executor executor, Predicate<String> contentTypePredicate,
    TransferListener<? super DataSource> transferListener,
    HttpDataSource.Factory fallbackFactory) {
  this(cronetEngineWrapper, executor, contentTypePredicate, transferListener,
      DEFAULT_CONNECT_TIMEOUT_MILLIS, DEFAULT_READ_TIMEOUT_MILLIS, false, fallbackFactory);
}

项目：transistor 文件：CronetDataSourceFactory.java

/**
 * Constructs a CronetDataSourceFactory.
 * <p>
 * If the {@link CronetEngineWrapper} fails to provide a {@link CronetEngine}, a
 * {@link DefaultHttpDataSourceFactory} will be used instead.
 *
 * Sets {@link CronetDataSource#DEFAULT_CONNECT_TIMEOUT_MILLIS} as the connection timeout, {@link
 * CronetDataSource#DEFAULT_READ_TIMEOUT_MILLIS} as the read timeout and disables
 * cross-protocol redirects.
 *
 * @param cronetEngineWrapper A {@link CronetEngineWrapper}.
 * @param executor The {@link java.util.concurrent.Executor} that will perform the requests.
 * @param contentTypePredicate An optional {@link Predicate}. If a content type is rejected by the
 *     predicate then an {@link InvalidContentTypeException} is thrown from
 *     {@link CronetDataSource#open}.
 * @param transferListener An optional listener.
 * @param userAgent A user agent used to create a fallback HttpDataSource if needed.
 */
public CronetDataSourceFactory(CronetEngineWrapper cronetEngineWrapper,
    Executor executor, Predicate<String> contentTypePredicate,
    TransferListener<? super DataSource> transferListener, String userAgent) {
  this(cronetEngineWrapper, executor, contentTypePredicate, transferListener,
      DEFAULT_CONNECT_TIMEOUT_MILLIS, DEFAULT_READ_TIMEOUT_MILLIS, false,
      new DefaultHttpDataSourceFactory(userAgent, transferListener,
          DEFAULT_CONNECT_TIMEOUT_MILLIS, DEFAULT_READ_TIMEOUT_MILLIS, false));
}

项目：transistor 文件：CronetDataSourceFactory.java

/**
 * Constructs a CronetDataSourceFactory.
 * <p>
 * If the {@link CronetEngineWrapper} fails to provide a {@link CronetEngine}, a
 * {@link DefaultHttpDataSourceFactory} will be used instead.
 *
 * @param cronetEngineWrapper A {@link CronetEngineWrapper}.
 * @param executor The {@link java.util.concurrent.Executor} that will perform the requests.
 * @param contentTypePredicate An optional {@link Predicate}. If a content type is rejected by the
 *     predicate then an {@link InvalidContentTypeException} is thrown from
 *     {@link CronetDataSource#open}.
 * @param transferListener An optional listener.
 * @param connectTimeoutMs The connection timeout, in milliseconds.
 * @param readTimeoutMs The read timeout, in milliseconds.
 * @param resetTimeoutOnRedirects Whether the connect timeout is reset when a redirect occurs.
 * @param userAgent A user agent used to create a fallback HttpDataSource if needed.
 */
public CronetDataSourceFactory(CronetEngineWrapper cronetEngineWrapper,
    Executor executor, Predicate<String> contentTypePredicate,
    TransferListener<? super DataSource> transferListener, int connectTimeoutMs,
    int readTimeoutMs, boolean resetTimeoutOnRedirects, String userAgent) {
  this(cronetEngineWrapper, executor, contentTypePredicate, transferListener,
      DEFAULT_CONNECT_TIMEOUT_MILLIS, DEFAULT_READ_TIMEOUT_MILLIS, resetTimeoutOnRedirects,
      new DefaultHttpDataSourceFactory(userAgent, transferListener, connectTimeoutMs,
          readTimeoutMs, resetTimeoutOnRedirects));
}

项目：transistor 文件：CronetDataSourceFactory.java

/**
 * Constructs a CronetDataSourceFactory.
 * <p>
 * If the {@link CronetEngineWrapper} fails to provide a {@link CronetEngine}, the provided
 * fallback {@link HttpDataSource.Factory} will be used instead.
 *
 * @param cronetEngineWrapper A {@link CronetEngineWrapper}.
 * @param executor The {@link java.util.concurrent.Executor} that will perform the requests.
 * @param contentTypePredicate An optional {@link Predicate}. If a content type is rejected by the
 *     predicate then an {@link InvalidContentTypeException} is thrown from
 *     {@link CronetDataSource#open}.
 * @param transferListener An optional listener.
 * @param connectTimeoutMs The connection timeout, in milliseconds.
 * @param readTimeoutMs The read timeout, in milliseconds.
 * @param resetTimeoutOnRedirects Whether the connect timeout is reset when a redirect occurs.
 * @param fallbackFactory A {@link HttpDataSource.Factory} which is used as a fallback in case
 *     no suitable CronetEngine can be build.
 */
public CronetDataSourceFactory(CronetEngineWrapper cronetEngineWrapper,
    Executor executor, Predicate<String> contentTypePredicate,
    TransferListener<? super DataSource> transferListener, int connectTimeoutMs,
    int readTimeoutMs, boolean resetTimeoutOnRedirects,
    HttpDataSource.Factory fallbackFactory) {
  this.cronetEngineWrapper = cronetEngineWrapper;
  this.executor = executor;
  this.contentTypePredicate = contentTypePredicate;
  this.transferListener = transferListener;
  this.connectTimeoutMs = connectTimeoutMs;
  this.readTimeoutMs = readTimeoutMs;
  this.resetTimeoutOnRedirects = resetTimeoutOnRedirects;
  this.fallbackFactory = fallbackFactory;
}

项目：transistor 文件：CronetDataSource.java

/**
 * @param cronetEngine A CronetEngine.
 * @param executor The {@link java.util.concurrent.Executor} that will handle responses.
 *     This may be a direct executor (i.e. executes tasks on the calling thread) in order
 *     to avoid a thread hop from Cronet's internal network thread to the response handling
 *     thread. However, to avoid slowing down overall network performance, care must be taken
 *     to make sure response handling is a fast operation when using a direct executor.
 * @param contentTypePredicate An optional {@link Predicate}. If a content type is rejected by the
 *     predicate then an {@link InvalidContentTypeException} is thrown from
 *     {@link #open(DataSpec)}.
 * @param listener An optional listener.
 * @param connectTimeoutMs The connection timeout, in milliseconds.
 * @param readTimeoutMs The read timeout, in milliseconds.
 * @param resetTimeoutOnRedirects Whether the connect timeout is reset when a redirect occurs.
 * @param defaultRequestProperties The default request properties to be used.
 */
public CronetDataSource(CronetEngine cronetEngine, Executor executor,
    Predicate<String> contentTypePredicate, TransferListener<? super CronetDataSource> listener,
    int connectTimeoutMs, int readTimeoutMs, boolean resetTimeoutOnRedirects,
    RequestProperties defaultRequestProperties) {
  this(cronetEngine, executor, contentTypePredicate, listener, connectTimeoutMs,
      readTimeoutMs, resetTimeoutOnRedirects, Clock.DEFAULT, defaultRequestProperties, false);
}

项目：transistor 文件：CronetDataSource.java

/**
 * @param cronetEngine A CronetEngine.
 * @param executor The {@link java.util.concurrent.Executor} that will handle responses.
 *     This may be a direct executor (i.e. executes tasks on the calling thread) in order
 *     to avoid a thread hop from Cronet's internal network thread to the response handling
 *     thread. However, to avoid slowing down overall network performance, care must be taken
 *     to make sure response handling is a fast operation when using a direct executor.
 * @param contentTypePredicate An optional {@link Predicate}. If a content type is rejected by the
 *     predicate then an {@link InvalidContentTypeException} is thrown from
 *     {@link #open(DataSpec)}.
 * @param listener An optional listener.
 * @param connectTimeoutMs The connection timeout, in milliseconds.
 * @param readTimeoutMs The read timeout, in milliseconds.
 * @param resetTimeoutOnRedirects Whether the connect timeout is reset when a redirect occurs.
 * @param defaultRequestProperties The default request properties to be used.
 * @param handleSetCookieRequests Whether "Set-Cookie" requests on redirect should be forwarded to
 *     the redirect url in the "Cookie" header.
 */
public CronetDataSource(CronetEngine cronetEngine, Executor executor,
    Predicate<String> contentTypePredicate, TransferListener<? super CronetDataSource> listener,
    int connectTimeoutMs, int readTimeoutMs, boolean resetTimeoutOnRedirects,
    RequestProperties defaultRequestProperties, boolean handleSetCookieRequests) {
  this(cronetEngine, executor, contentTypePredicate, listener, connectTimeoutMs,
      readTimeoutMs, resetTimeoutOnRedirects, Clock.DEFAULT, defaultRequestProperties,
      handleSetCookieRequests);
}

项目：transistor 文件：DefaultHttpDataSource.java

/**
 * @param userAgent The User-Agent string that should be used.
 * @param contentTypePredicate An optional {@link Predicate}. If a content type is rejected by the
 *     predicate then a {@link HttpDataSource.InvalidContentTypeException} is thrown from
 *     {@link #open(DataSpec)}.
 * @param listener An optional listener.
 * @param connectTimeoutMillis The connection timeout, in milliseconds. A timeout of zero is
 *     interpreted as an infinite timeout.
 * @param readTimeoutMillis The read timeout, in milliseconds. A timeout of zero is interpreted
 *     as an infinite timeout.
 */
public DefaultHttpDataSource(String userAgent, Predicate<String> contentTypePredicate,
    TransferListener<? super DefaultHttpDataSource> listener, int connectTimeoutMillis,
    int readTimeoutMillis) {
  this(userAgent, contentTypePredicate, listener, connectTimeoutMillis, readTimeoutMillis, false,
      null);
}

项目：transistor 文件：DefaultHttpDataSource.java

/**
 * @param userAgent The User-Agent string that should be used.
 * @param contentTypePredicate An optional {@link Predicate}. If a content type is rejected by the
 *     predicate then a {@link HttpDataSource.InvalidContentTypeException} is thrown from
 *     {@link #open(DataSpec)}.
 * @param listener An optional listener.
 * @param connectTimeoutMillis The connection timeout, in milliseconds. A timeout of zero is
 *     interpreted as an infinite timeout. Pass {@link #DEFAULT_CONNECT_TIMEOUT_MILLIS} to use
 *     the default value.
 * @param readTimeoutMillis The read timeout, in milliseconds. A timeout of zero is interpreted
 *     as an infinite timeout. Pass {@link #DEFAULT_READ_TIMEOUT_MILLIS} to use the default value.
 * @param allowCrossProtocolRedirects Whether cross-protocol redirects (i.e. redirects from HTTP
 *     to HTTPS and vice versa) are enabled.
 * @param defaultRequestProperties The default request properties to be sent to the server as
 *     HTTP headers or {@code null} if not required.
 */
public DefaultHttpDataSource(String userAgent, Predicate<String> contentTypePredicate,
    TransferListener<? super DefaultHttpDataSource> listener, int connectTimeoutMillis,
    int readTimeoutMillis, boolean allowCrossProtocolRedirects,
    RequestProperties defaultRequestProperties) {
  this.userAgent = Assertions.checkNotEmpty(userAgent);
  this.contentTypePredicate = contentTypePredicate;
  this.listener = listener;
  this.requestProperties = new RequestProperties();
  this.connectTimeoutMillis = connectTimeoutMillis;
  this.readTimeoutMillis = readTimeoutMillis;
  this.allowCrossProtocolRedirects = allowCrossProtocolRedirects;
  this.defaultRequestProperties = defaultRequestProperties;
}

项目：Phoenix-for-VK 文件：CustomHttpDataSource.java

/**
 * @param userAgent            The User-Agent string that should be used.
 * @param contentTypePredicate An optional {@link Predicate}. If a content type is rejected by the
 *                             predicate then a {@link InvalidContentTypeException} is thrown from
 *                             {@link #open(DataSpec)}.
 */
public CustomHttpDataSource(String userAgent, Predicate<String> contentTypePredicate, Proxy proxy) {
    this(userAgent, contentTypePredicate, null, proxy);
}

项目：Phoenix-for-VK 文件：CustomHttpDataSource.java

/**
 * @param userAgent            The User-Agent string that should be used.
 * @param contentTypePredicate An optional {@link Predicate}. If a content type is rejected by the
 *                             predicate then a {@link InvalidContentTypeException} is thrown from
 *                             {@link #open(DataSpec)}.
 * @param listener             An optional listener.
 */
public CustomHttpDataSource(String userAgent, Predicate<String> contentTypePredicate, TransferListener<? super CustomHttpDataSource> listener, Proxy proxy) {
    this(userAgent, contentTypePredicate, listener, DEFAULT_CONNECT_TIMEOUT_MILLIS,
            DEFAULT_READ_TIMEOUT_MILLIS, proxy);
}

项目：Exoplayer2Radio 文件：DefaultHttpDataSource.java

/**
 * @param userAgent The User-Agent string that should be used.
 * @param contentTypePredicate An optional {@link Predicate}. If a content type is rejected by the
 *     predicate then a {@link HttpDataSource.InvalidContentTypeException} is thrown from
 *     {@link #open(DataSpec)}.
 */
public DefaultHttpDataSource(String userAgent, Predicate<String> contentTypePredicate) {
  this(userAgent, contentTypePredicate, null);
}

项目：Exoplayer2Radio 文件：DefaultHttpDataSource.java

/**
 * @param userAgent The User-Agent string that should be used.
 * @param contentTypePredicate An optional {@link Predicate}. If a content type is rejected by the
 *     predicate then a {@link HttpDataSource.InvalidContentTypeException} is thrown from
 *     {@link #open(DataSpec)}.
 * @param listener An optional listener.
 */
public DefaultHttpDataSource(String userAgent, Predicate<String> contentTypePredicate,
    TransferListener<? super DefaultHttpDataSource> listener) {
  this(userAgent, contentTypePredicate, listener, DEFAULT_CONNECT_TIMEOUT_MILLIS,
      DEFAULT_READ_TIMEOUT_MILLIS);
}

项目：K-Sonic 文件：DefaultHttpDataSource.java

/**
 * @param userAgent The User-Agent string that should be used.
 * @param contentTypePredicate An optional {@link Predicate}. If a content type is rejected by the
 *     predicate then a {@link HttpDataSource.InvalidContentTypeException} is thrown from
 *     {@link #open(DataSpec)}.
 */
public DefaultHttpDataSource(String userAgent, Predicate<String> contentTypePredicate) {
  this(userAgent, contentTypePredicate, null);
}

项目：K-Sonic 文件：DefaultHttpDataSource.java

/**
 * @param userAgent The User-Agent string that should be used.
 * @param contentTypePredicate An optional {@link Predicate}. If a content type is rejected by the
 *     predicate then a {@link HttpDataSource.InvalidContentTypeException} is thrown from
 *     {@link #open(DataSpec)}.
 * @param listener An optional listener.
 */
public DefaultHttpDataSource(String userAgent, Predicate<String> contentTypePredicate,
    TransferListener<? super DefaultHttpDataSource> listener) {
  this(userAgent, contentTypePredicate, listener, DEFAULT_CONNECT_TIMEOUT_MILLIS,
      DEFAULT_READ_TIMEOUT_MILLIS);
}

项目：videoPickPlayer 文件：DefaultHttpDataSource.java

/**
 * @param userAgent The User-Agent string that should be used.
 * @param contentTypePredicate An optional {@link Predicate}. If a content type is rejected by the
 *     predicate then a {@link HttpDataSource.InvalidContentTypeException} is thrown from
 *     {@link #open(DataSpec)}.
 */
public DefaultHttpDataSource(String userAgent, Predicate<String> contentTypePredicate) {
  this(userAgent, contentTypePredicate, null);
}

项目：videoPickPlayer 文件：DefaultHttpDataSource.java

/**
 * @param userAgent The User-Agent string that should be used.
 * @param contentTypePredicate An optional {@link Predicate}. If a content type is rejected by the
 *     predicate then a {@link HttpDataSource.InvalidContentTypeException} is thrown from
 *     {@link #open(DataSpec)}.
 * @param listener An optional listener.
 */
public DefaultHttpDataSource(String userAgent, Predicate<String> contentTypePredicate,
    TransferListener<? super DefaultHttpDataSource> listener) {
  this(userAgent, contentTypePredicate, listener, DEFAULT_CONNECT_TIMEOUT_MILLIS,
      DEFAULT_READ_TIMEOUT_MILLIS);
}

项目：videoPickPlayer 文件：DefaultHttpDataSource.java

/**
 * @param userAgent The User-Agent string that should be used.
 * @param contentTypePredicate An optional {@link Predicate}. If a content type is rejected by the
 *     predicate then a {@link HttpDataSource.InvalidContentTypeException} is thrown from
 *     {@link #open(DataSpec)}.
 * @param listener An optional listener.
 * @param connectTimeoutMillis The connection timeout, in milliseconds. A timeout of zero is
 *     interpreted as an infinite timeout.
 * @param readTimeoutMillis The read timeout, in milliseconds. A timeout of zero is interpreted
 *     as an infinite timeout.
 */
public DefaultHttpDataSource(String userAgent, Predicate<String> contentTypePredicate,
    TransferListener<? super DefaultHttpDataSource> listener, int connectTimeoutMillis,
    int readTimeoutMillis) {
  this(userAgent, contentTypePredicate, listener, connectTimeoutMillis, readTimeoutMillis, false);
}

项目：transistor 文件：CronetDataSource.java

/**
 * @param cronetEngine A CronetEngine.
 * @param executor The {@link java.util.concurrent.Executor} that will handle responses.
 *     This may be a direct executor (i.e. executes tasks on the calling thread) in order
 *     to avoid a thread hop from Cronet's internal network thread to the response handling
 *     thread. However, to avoid slowing down overall network performance, care must be taken
 *     to make sure response handling is a fast operation when using a direct executor.
 * @param contentTypePredicate An optional {@link Predicate}. If a content type is rejected by the
 *     predicate then an {@link InvalidContentTypeException} is thrown from
 *     {@link #open(DataSpec)}.
 * @param listener An optional listener.
 */
public CronetDataSource(CronetEngine cronetEngine, Executor executor,
    Predicate<String> contentTypePredicate, TransferListener<? super CronetDataSource> listener) {
  this(cronetEngine, executor, contentTypePredicate, listener, DEFAULT_CONNECT_TIMEOUT_MILLIS,
      DEFAULT_READ_TIMEOUT_MILLIS, false, null, false);
}

项目：transistor 文件：OkHttpDataSource.java

/**
 * @param callFactory A {@link Call.Factory} (typically an {@link okhttp3.OkHttpClient}) for use
 *     by the source.
 * @param userAgent An optional User-Agent string.
 * @param contentTypePredicate An optional {@link Predicate}. If a content type is rejected by the
 *     predicate then a InvalidContentTypeException} is thrown from {@link #open(DataSpec)}.
 */
public OkHttpDataSource(@NonNull Call.Factory callFactory, @Nullable String userAgent,
    @Nullable Predicate<String> contentTypePredicate) {
  this(callFactory, userAgent, contentTypePredicate, null);
}

项目：transistor 文件：OkHttpDataSource.java

/**
 * @param callFactory A {@link Call.Factory} (typically an {@link okhttp3.OkHttpClient}) for use
 *     by the source.
 * @param userAgent An optional User-Agent string.
 * @param contentTypePredicate An optional {@link Predicate}. If a content type is rejected by the
 *     predicate then a {@link InvalidContentTypeException} is thrown from
 *     {@link #open(DataSpec)}.
 * @param listener An optional listener.
 */
public OkHttpDataSource(@NonNull Call.Factory callFactory, @Nullable String userAgent,
    @Nullable Predicate<String> contentTypePredicate,
    @Nullable TransferListener<? super OkHttpDataSource> listener) {
  this(callFactory, userAgent, contentTypePredicate, listener, null, null);
}

项目：transistor 文件：DefaultHttpDataSource.java

/**
 * @param userAgent The User-Agent string that should be used.
 * @param contentTypePredicate An optional {@link Predicate}. If a content type is rejected by the
 *     predicate then a {@link HttpDataSource.InvalidContentTypeException} is thrown from
 *     {@link #open(DataSpec)}.
 */
public DefaultHttpDataSource(String userAgent, Predicate<String> contentTypePredicate) {
  this(userAgent, contentTypePredicate, null);
}

项目：transistor 文件：DefaultHttpDataSource.java

/**
 * @param userAgent The User-Agent string that should be used.
 * @param contentTypePredicate An optional {@link Predicate}. If a content type is rejected by the
 *     predicate then a {@link HttpDataSource.InvalidContentTypeException} is thrown from
 *     {@link #open(DataSpec)}.
 * @param listener An optional listener.
 */
public DefaultHttpDataSource(String userAgent, Predicate<String> contentTypePredicate,
    TransferListener<? super DefaultHttpDataSource> listener) {
  this(userAgent, contentTypePredicate, listener, DEFAULT_CONNECT_TIMEOUT_MILLIS,
      DEFAULT_READ_TIMEOUT_MILLIS);
}