com.android.volley.RequestQueue.stop()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(10.4k)|赞(0)|评价(0)|浏览(128)

本文整理了Java中com.android.volley.RequestQueue.stop方法的一些代码示例，展示了RequestQueue.stop的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。RequestQueue.stop方法的具体详情如下：
包路径：com.android.volley.RequestQueue
类名称：RequestQueue
方法名：stop

RequestQueue.stop介绍

[英]Stops the cache and network dispatchers.
[中]停止缓存和网络调度器。

代码示例

代码示例来源：origin: bumptech/glide

@After
public void tearDown() throws IOException {
 mockWebServer.shutdown();
 requestQueue.stop();
}

代码示例来源：origin: chentao0707/SimplifyReader

/**
 * Starts the dispatchers in this queue.
 */
public void start() {
  stop();  // Make sure any currently running dispatchers are stopped.
  // Create the cache dispatcher and start it.
  mCacheDispatcher = new CacheDispatcher(mCacheQueue, mNetworkQueue, mCache, mDelivery);
  mCacheDispatcher.start();
  // Create network dispatchers (and corresponding threads) up to the pool size.
  for (int i = 0; i < mDispatchers.length; i++) {
    NetworkDispatcher networkDispatcher = new NetworkDispatcher(mNetworkQueue, mNetwork,
        mCache, mDelivery);
    mDispatchers[i] = networkDispatcher;
    networkDispatcher.start();
  }
}

代码示例来源：origin: mcxiaoke/android-volley

/**
 * Starts the dispatchers in this queue.
 */
public void start() {
  stop();  // Make sure any currently running dispatchers are stopped.
  // Create the cache dispatcher and start it.
  mCacheDispatcher = new CacheDispatcher(mCacheQueue, mNetworkQueue, mCache, mDelivery);
  mCacheDispatcher.start();
  // Create network dispatchers (and corresponding threads) up to the pool size.
  for (int i = 0; i < mDispatchers.length; i++) {
    NetworkDispatcher networkDispatcher = new NetworkDispatcher(mNetworkQueue, mNetwork,
        mCache, mDelivery);
    mDispatchers[i] = networkDispatcher;
    networkDispatcher.start();
  }
}

代码示例来源：origin: jiangqqlmj/FastDev4Android

/**
 * Starts the dispatchers in this queue.
 */
public void start() {
  stop();  // Make sure any currently running dispatchers are stopped.
  // Create the cache dispatcher and start it.
  mCacheDispatcher = new CacheDispatcher(mCacheQueue, mNetworkQueue, mCache, mDelivery);
  mCacheDispatcher.start();
  // Create network dispatchers (and corresponding threads) up to the pool size.
  for (int i = 0; i < mDispatchers.length; i++) {
    NetworkDispatcher networkDispatcher = new NetworkDispatcher(mNetworkQueue, mNetwork,
        mCache, mDelivery);
    mDispatchers[i] = networkDispatcher;
    networkDispatcher.start();
  }
}

代码示例来源：origin: mcxiaoke/android-volley

/**
 * Verify RequestFinishedListeners are informed when request errors
 *
 * Needs to be an integration test because relies on Request -> dispatcher -> RequestQueue interaction
 */
@Test public void add_requestFinishedListenerError() throws Exception {
  RequestFinishedListener listener = mock(RequestFinishedListener.class);
  Request request = new MockRequest();
  RequestQueue queue = new RequestQueue(new NoCache(), mMockNetwork, 1, mDelivery);
  when(mMockNetwork.performRequest(request)).thenThrow(new VolleyError());
  queue.addRequestFinishedListener(listener);
  queue.start();
  queue.add(request);
  verify(listener, timeout(100)).onRequestFinished(request);
  queue.stop();
}

代码示例来源：origin: mcxiaoke/android-volley

/**
 * Verify RequestFinishedListeners are informed when requests are successfully delivered
 *
 * Needs to be an integration test because relies on Request -> dispatcher -> RequestQueue interaction
 */
@Test public void add_requestFinishedListenerSuccess() throws Exception {
  NetworkResponse response = mock(NetworkResponse.class);
  Request request = new MockRequest();
  RequestFinishedListener listener = mock(RequestFinishedListener.class);
  RequestFinishedListener listener2 = mock(RequestFinishedListener.class);
  RequestQueue queue = new RequestQueue(new NoCache(), mMockNetwork, 1, mDelivery);
  queue.addRequestFinishedListener(listener);
  queue.addRequestFinishedListener(listener2);
  queue.start();
  queue.add(request);
  verify(listener, timeout(100)).onRequestFinished(request);
  verify(listener2, timeout(100)).onRequestFinished(request);
  queue.stop();
}

代码示例来源：origin: jiangqqlmj/FastDev4Android

/**
 * Verify RequestFinishedListeners are informed when request errors
 *
 * Needs to be an integration test because relies on Request -> dispatcher -> RequestQueue interaction
 */
@Test public void add_requestFinishedListenerError() throws Exception {
  RequestFinishedListener listener = mock(RequestFinishedListener.class);
  Request request = new MockRequest();
  RequestQueue queue = new RequestQueue(new NoCache(), mMockNetwork, 1, mDelivery);
  when(mMockNetwork.performRequest(request)).thenThrow(new VolleyError());
  queue.addRequestFinishedListener(listener);
  queue.start();
  queue.add(request);
  verify(listener, timeout(100)).onRequestFinished(request);
  queue.stop();
}

代码示例来源：origin: mcxiaoke/android-volley

verify(listener, timeout(100)).onRequestFinished(req1);
verify(listener, timeout(10)).onRequestFinished(req2);
queue.stop();

代码示例来源：origin: jiangqqlmj/FastDev4Android

/**
 * Verify RequestFinishedListeners are informed when requests are successfully delivered
 *
 * Needs to be an integration test because relies on Request -> dispatcher -> RequestQueue interaction
 */
@Test public void add_requestFinishedListenerSuccess() throws Exception {
  NetworkResponse response = mock(NetworkResponse.class);
  Request request = new MockRequest();
  RequestFinishedListener listener = mock(RequestFinishedListener.class);
  RequestFinishedListener listener2 = mock(RequestFinishedListener.class);
  RequestQueue queue = new RequestQueue(new NoCache(), mMockNetwork, 1, mDelivery);
  queue.addRequestFinishedListener(listener);
  queue.addRequestFinishedListener(listener2);
  queue.start();
  queue.add(request);
  verify(listener, timeout(100)).onRequestFinished(request);
  verify(listener2, timeout(100)).onRequestFinished(request);
  queue.stop();
}

代码示例来源：origin: jiangqqlmj/FastDev4Android

verify(listener, timeout(100)).onRequestFinished(req1);
verify(listener, timeout(10)).onRequestFinished(req2);
queue.stop();

代码示例来源：origin: mcxiaoke/android-volley

/**
 * Verify RequestFinishedListeners are informed when requests are canceled
 *
 * Needs to be an integration test because relies on Request -> dispatcher -> RequestQueue interaction
 */
@Test public void add_requestFinishedListenerCanceled() throws Exception {
  RequestFinishedListener listener = mock(RequestFinishedListener.class);
  Request request = new MockRequest();
  Answer<NetworkResponse> delayAnswer = new Answer<NetworkResponse>() {
    @Override
    public NetworkResponse answer(InvocationOnMock invocationOnMock) throws Throwable {
      Thread.sleep(200);
      return mock(NetworkResponse.class);
    }
  };
  RequestQueue queue = new RequestQueue(new NoCache(), mMockNetwork, 1, mDelivery);
  when(mMockNetwork.performRequest(request)).thenAnswer(delayAnswer);
  queue.addRequestFinishedListener(listener);
  queue.start();
  queue.add(request);
  request.cancel();
  verify(listener, timeout(100)).onRequestFinished(request);
  queue.stop();
}

代码示例来源：origin: jiangqqlmj/FastDev4Android

/**
 * Verify RequestFinishedListeners are informed when requests are canceled
 *
 * Needs to be an integration test because relies on Request -> dispatcher -> RequestQueue interaction
 */
@Test public void add_requestFinishedListenerCanceled() throws Exception {
  RequestFinishedListener listener = mock(RequestFinishedListener.class);
  Request request = new MockRequest();
  Answer<NetworkResponse> delayAnswer = new Answer<NetworkResponse>() {
    @Override
    public NetworkResponse answer(InvocationOnMock invocationOnMock) throws Throwable {
      Thread.sleep(200);
      return mock(NetworkResponse.class);
    }
  };
  RequestQueue queue = new RequestQueue(new NoCache(), mMockNetwork, 1, mDelivery);
  when(mMockNetwork.performRequest(request)).thenAnswer(delayAnswer);
  queue.addRequestFinishedListener(listener);
  queue.start();
  queue.add(request);
  request.cancel();
  verify(listener, timeout(100)).onRequestFinished(request);
  queue.stop();
}

代码示例来源：origin: mcxiaoke/android-volley

queue.stop();

代码示例来源：origin: jiangqqlmj/FastDev4Android

queue.stop();

代码示例来源：origin: lynfogeek/conference-app

public void stop() {
    getRequestQueue().stop();
  }
}

代码示例来源：origin: MewX/light-novel-library_Wenku8_Android

/**
 * Starts the dispatchers in this queue.
 */
public void start() {
  stop();  // Make sure any currently running dispatchers are stopped.
  // Create the cache dispatcher and start it.
  mCacheDispatcher = new CacheDispatcher(mCacheQueue, mNetworkQueue, mCache, mDelivery);
  mCacheDispatcher.start();
  // Create network dispatchers (and corresponding threads) up to the pool size.
  for (int i = 0; i < mDispatchers.length; i++) {
    NetworkDispatcher networkDispatcher = new NetworkDispatcher(mNetworkQueue, mNetwork,
        mCache, mDelivery);
    mDispatchers[i] = networkDispatcher;
    networkDispatcher.start();
  }
}

代码示例来源：origin: com.mcxiaoke.volley/library

/**
 * Starts the dispatchers in this queue.
 */
public void start() {
  stop();  // Make sure any currently running dispatchers are stopped.
  // Create the cache dispatcher and start it.
  mCacheDispatcher = new CacheDispatcher(mCacheQueue, mNetworkQueue, mCache, mDelivery);
  mCacheDispatcher.start();
  // Create network dispatchers (and corresponding threads) up to the pool size.
  for (int i = 0; i < mDispatchers.length; i++) {
    NetworkDispatcher networkDispatcher = new NetworkDispatcher(mNetworkQueue, mNetwork,
        mCache, mDelivery);
    mDispatchers[i] = networkDispatcher;
    networkDispatcher.start();
  }
}

代码示例来源：origin: chuyangliu/tastysnake

/**
 * Starts the dispatchers in this queue.
 */
public void start() {
  stop();  // Make sure any currently running dispatchers are stopped.
  // Create the cache dispatcher and start it.
  mCacheDispatcher = new CacheDispatcher(mCacheQueue, mNetworkQueue, mCache, mDelivery);
  mCacheDispatcher.start();
  // Create network dispatchers (and corresponding threads) up to the pool size.
  for (int i = 0; i < mDispatchers.length; i++) {
    NetworkDispatcher networkDispatcher = new NetworkDispatcher(mNetworkQueue, mNetwork,
        mCache, mDelivery);
    mDispatchers[i] = networkDispatcher;
    networkDispatcher.start();
  }
}

代码示例来源：origin: chuyangliu/tastysnake

/**
 * Verify RequestFinishedListeners are informed when request errors
 *
 * Needs to be an integration test because relies on Request -> dispatcher -> RequestQueue interaction
 */
@Test public void add_requestFinishedListenerError() throws Exception {
  RequestFinishedListener listener = mock(RequestFinishedListener.class);
  Request request = new MockRequest();
  RequestQueue queue = new RequestQueue(new NoCache(), mMockNetwork, 1, mDelivery);
  when(mMockNetwork.performRequest(request)).thenThrow(new VolleyError());
  queue.addRequestFinishedListener(listener);
  queue.start();
  queue.add(request);
  verify(listener, timeout(100)).onRequestFinished(request);
  queue.stop();
}

代码示例来源：origin: MewX/light-novel-library_Wenku8_Android

/**
 * Verify RequestFinishedListeners are informed when request errors
 *
 * Needs to be an integration test because relies on Request -> dispatcher -> RequestQueue interaction
 */
@Test public void add_requestFinishedListenerError() throws Exception {
  RequestFinishedListener listener = mock(RequestFinishedListener.class);
  Request request = new MockRequest();
  RequestQueue queue = new RequestQueue(new NoCache(), mMockNetwork, 1, mDelivery);
  when(mMockNetwork.performRequest(request)).thenThrow(new VolleyError());
  queue.addRequestFinishedListener(listener);
  queue.start();
  queue.add(request);
  verify(listener, timeout(TIMEOUT)).onRequestFinished(request);
  queue.stop();
}

内容来源于网络，如有侵权，请联系作者删除！

RequestQueue

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com