org.easymock.EasyMock.newCapture()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(11.4k)|赞(0)|评价(0)|浏览(115)

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

EasyMock.newCapture介绍

[英]Create a new capture instance that will keep only the last captured value.
[中]创建一个新的捕获实例，该实例将只保留最后捕获的值。

代码示例

代码示例来源：origin: confluentinc/ksql

  1. @Test
  2. public void testStopSendingAfterClose() {
  3.  replayOnSubscribe();
  4.  EasyMock.expect(session.getAsyncRemote()).andReturn(async).anyTimes();
  5.  final Capture<String> json = EasyMock.newCapture(CaptureType.ALL);
  6.  async.sendText(EasyMock.capture(json), EasyMock.anyObject());
  7.  subscription.request(1);
  8.  subscription.cancel();
  9.  EasyMock.replay(subscription, session, async);
  10.  subscriber.onNext(ImmutableList.of(ImmutableMap.of("a", 1)));
  11.  subscriber.close();
  12.  subscriber.onNext(ImmutableList.of(ImmutableMap.of("b", 2), ImmutableMap.of("c", 3)));
  13.  assertEquals(ImmutableList.of("{\"a\":1}"), json.getValues());
  14.  EasyMock.verify(subscription, session, async);
  15. }

代码示例来源：origin: JanusGraph/janusgraph

  1. txConfigCapture = EasyMock.newCapture(CaptureType.ALL);
  2. inconsistentTx = ctrl.createMock(StoreTransaction.class);
  3. consistentTx = ctrl.createMock(StoreTransaction.class);

代码示例来源：origin: confluentinc/ksql

  1. @Before
  2. public void setUp() {
  3.  objectMapper = JsonMapper.INSTANCE.mapper;
  4.  ehCapture = newCapture();
  5.  drainCapture = newCapture();
  6.  limitHandlerCapture = newCapture();
  7.  final Schema schema = SchemaBuilder.struct().field("col1", Schema.OPTIONAL_STRING_SCHEMA).build();
  8.  final KafkaStreams kStreams = niceMock(KafkaStreams.class);
  9.  kStreams.setStateListener(anyObject());
  10.  expectLastCall();
  11.  expect(kStreams.state()).andReturn(State.RUNNING);
  12.  expect(queryMetadata.getRowQueue()).andReturn(rowQueue).anyTimes();
  13.  expect(queryMetadata.getResultSchema()).andReturn(schema).anyTimes();
  14.  queryMetadata.setLimitHandler(capture(limitHandlerCapture));
  15.  expectLastCall().once();
  16.  queryMetadata.setUncaughtExceptionHandler(capture(ehCapture));
  17.  expectLastCall();
  18.  replay(kStreams);
  19. }

代码示例来源：origin: apache/incubator-druid

  1. );
  2. final Capture<ServiceEventBuilder<ServiceMetricEvent>> eventCapture = EasyMock.newCapture(CaptureType.ALL);
  3. serviceEmitter.emit(EasyMock.capture(eventCapture));
  4. EasyMock.expectLastCall().times(5);

代码示例来源：origin: googleapis/google-cloud-java

  1. @Test
  2. public void testCreateJobSuccess() {
  3.  String id = "testCreateJobSuccess-id";
  4.  JobId jobId = JobId.of(id);
  5.  String query = "SELECT * in FOO";
  6.  Capture<com.google.api.services.bigquery.model.Job> jobCapture = EasyMock.newCapture();
  7.  EasyMock.expect(
  8.      bigqueryRpcMock.create(EasyMock.capture(jobCapture), EasyMock.eq(EMPTY_RPC_OPTIONS)))
  9.    .andReturn(newJobPb());
  10.  EasyMock.replay(bigqueryRpcMock);
  11.  bigquery = options.getService();
  12.  assertThat(bigquery.create(JobInfo.of(jobId, QueryJobConfiguration.of(query)))).isNotNull();
  13.  assertThat(jobCapture.getValue().getJobReference().getJobId()).isEqualTo(id);
  14. }

代码示例来源：origin: confluentinc/ksql

  1. @Test
  2. public void testSanity() throws Exception {
  3.  replayOnSubscribe();
  4.  EasyMock.expect(session.getAsyncRemote()).andReturn(async).anyTimes();
  5.  final Capture<String> json = EasyMock.newCapture(CaptureType.ALL);
  6.  async.sendText(EasyMock.capture(json), EasyMock.anyObject());
  7.  EasyMock.expectLastCall().times(3);
  8.  subscription.request(1);
  9.  EasyMock.expectLastCall().once();
  10.  session.close(EasyMock.anyObject());
  11.  EasyMock.expectLastCall().once();
  12.  subscription.cancel();
  13.  EasyMock.replay(subscription, session, async);
  14.  subscriber.onNext(ImmutableList.of(ImmutableMap.of("a", 1), ImmutableMap.of("b", 2), ImmutableMap.of("c", 3)));
  15.  assertEquals(ImmutableList.of("{\"a\":1}","{\"b\":2}","{\"c\":3}"), json.getValues());
  16.  subscriber.onComplete();
  17.  subscriber.close();
  18.  EasyMock.verify(subscription, session, async);
  19. }

代码示例来源：origin: apache/incubator-druid

  1. final CountDownLatch queryIsRegistered = new CountDownLatch(1);
  2. Capture<ListenableFuture> capturedFuture = EasyMock.newCapture();
  3. QueryWatcher watcher = EasyMock.createStrictMock(QueryWatcher.class);
  4. watcher.registerQuery(

代码示例来源：origin: confluentinc/ksql

  1. @Test
  2.  public void testOnError() throws Exception {
  3.   replayOnSubscribe();
  5.   final Capture<CloseReason> reason = EasyMock.newCapture();
  6.   EasyMock.expect(session.getId()).andReturn("abc123").once();
  7.   session.close(EasyMock.capture(reason));
  8.   EasyMock.expectLastCall().once();
  9.   subscription.cancel();
  10.   EasyMock.expectLastCall().once();
  12.   EasyMock.replay(subscription, session);
  14.   subscriber.onError(new RuntimeException("streams died"));
  15.   subscriber.close();
  17.   assertEquals("streams exception", reason.getValue().getReasonPhrase());
  18.   assertEquals(CloseCodes.UNEXPECTED_CONDITION, reason.getValue().getCloseCode());
  20.   EasyMock.verify(subscription, session);
  21.  }
  22. }

代码示例来源：origin: apache/incubator-druid

  1. Capture<Request> capturedRequest = EasyMock.newCapture();
  2. ListenableFuture<Object> cancelledFuture = Futures.immediateCancelledFuture();
  3. SettableFuture<Object> cancellationFuture = SettableFuture.create();

代码示例来源：origin: apache/incubator-druid

  1. final Capture<Iterable<Cache.NamedKey>> cacheKeyCapture = EasyMock.newCapture();
  2. EasyMock.expect(cache.getBulk(EasyMock.capture(cacheKeyCapture)))
  3.     .andReturn(ImmutableMap.of())

代码示例来源：origin: apache/incubator-druid

  1. Capture<Request> capturedRequest = EasyMock.newCapture();
  2. String hostName = "localhost:8080";
  3. EasyMock.expect(

代码示例来源：origin: googleapis/google-cloud-java

  1. @Test
  2. public void testCreateJobNoGet() {
  3.  String id = "testCreateJobNoGet-id";
  4.  JobId jobId = JobId.of(id);
  5.  String query = "SELECT * in FOO";
  6.  Capture<com.google.api.services.bigquery.model.Job> jobCapture = EasyMock.newCapture();
  7.  EasyMock.expect(
  8.      bigqueryRpcMock.create(EasyMock.capture(jobCapture), EasyMock.eq(EMPTY_RPC_OPTIONS)))
  9.    .andThrow(new BigQueryException(409, "already exists, for some reason"));
  10.  EasyMock.replay(bigqueryRpcMock);
  11.  bigquery = options.getService();
  12.  try {
  13.   bigquery.create(JobInfo.of(jobId, QueryJobConfiguration.of(query)));
  14.   fail("should throw");
  15.  } catch (BigQueryException e) {
  16.   assertThat(jobCapture.getValue().getJobReference().getJobId()).isEqualTo(id);
  17.  }
  18. }

代码示例来源：origin: googleapis/google-cloud-java

  1. @Test
  2. public void testCreateJobTryGet() {
  3.  final String id = "testCreateJobTryGet-id";
  4.  String query = "SELECT * in FOO";
  5.  Supplier<JobId> idProvider =
  6.    new Supplier<JobId>() {
  7.     @Override
  8.     public JobId get() {
  9.      return JobId.of(id);
  10.     }
  11.    };
  12.  Capture<com.google.api.services.bigquery.model.Job> jobCapture = EasyMock.newCapture();
  13.  EasyMock.expect(
  14.      bigqueryRpcMock.create(EasyMock.capture(jobCapture), EasyMock.eq(EMPTY_RPC_OPTIONS)))
  15.    .andThrow(new BigQueryException(409, "already exists, for some reason"));
  16.  EasyMock.expect(
  17.      bigqueryRpcMock.getJob(
  18.        anyString(),
  19.        EasyMock.eq(id),
  20.        EasyMock.eq((String) null),
  21.        EasyMock.eq(EMPTY_RPC_OPTIONS)))
  22.    .andReturn(newJobPb());
  23.  EasyMock.replay(bigqueryRpcMock);
  24.  bigquery = options.getService();
  25.  ((BigQueryImpl) bigquery).create(JobInfo.of(QueryJobConfiguration.of(query)), idProvider);
  26.  assertThat(jobCapture.getValue().getJobReference().getJobId()).isEqualTo(id);
  27. }

代码示例来源：origin: confluentinc/ksql

  1. @Test
  2. public void testOnSchema() throws Exception {
  3.  replayOnSubscribe();
  4.  session.getBasicRemote();
  5.  EasyMock.expectLastCall().andReturn(basic).once();
  6.  final Capture<String> schema = EasyMock.newCapture();
  7.  basic.sendText(EasyMock.capture(schema));
  8.  EasyMock.expectLastCall().andThrow(new IOException("bad bad io")).once();
  9.  final Capture<CloseReason> reason = EasyMock.newCapture();
  10.  session.close(EasyMock.capture(reason));
  11.  subscription.cancel();
  12.  EasyMock.replay(subscription, session, basic);
  13.  subscriber.onSchema(SchemaBuilder
  14.              .struct()
  15.    .field("currency", Schema.STRING_SCHEMA)
  16.    .field("amount", Schema.OPTIONAL_FLOAT32_SCHEMA)
  17.              .build());
  18.  subscriber.close();
  19.  assertEquals(
  20.    "[" +
  21.      "{\"name\":\"currency\"," +
  22.      "\"schema\":{\"type\":\"STRING\",\"fields\":null,\"memberSchema\":null}}," +
  23.      "{\"name\":\"amount\"," +
  24.      "\"schema\":{\"type\":\"DOUBLE\",\"fields\":null,\"memberSchema\":null}}]"
  25.    , schema.getValue());
  26.  assertEquals("Unable to send schema", reason.getValue().getReasonPhrase());
  27.  assertEquals(CloseCodes.PROTOCOL_ERROR, reason.getValue().getCloseCode());
  28.  EasyMock.verify(subscription, session, basic);
  29. }

代码示例来源：origin: apache/incubator-druid

  1. Capture<Request> capturedRequest = EasyMock.newCapture();
  2. EasyMock.expect(
  3.   httpClient.go(

代码示例来源：origin: apache/httpcomponents-client

  1. private void testDoesNotModifyHeaderOnRequests(final String headerName) throws Exception {
  2.   final String headerValue = HttpTestUtils.getCanonicalHeaderValue(request, headerName);
  3.   final Capture<ClassicHttpRequest> cap = EasyMock.newCapture();
  4.   EasyMock.expect(
  5.       mockExecChain.proceed(
  6.           EasyMock.capture(cap),
  7.           EasyMock.isA(ExecChain.Scope.class))).andReturn(originResponse);
  8.   replayMocks();
  9.   execute(request);
  10.   verifyMocks();
  11.   assertEquals(headerValue,
  12.       HttpTestUtils.getCanonicalHeaderValue(cap.getValue(),
  13.           headerName));
  14. }

代码示例来源：origin: apache/httpcomponents-client

  1. @Test
  2. public void testDoesNotAddAMaxForwardsHeaderToForwardedOPTIONSRequests() throws Exception {
  3.   request = new BasicClassicHttpRequest("OPTIONS", "/");
  4.   final Capture<ClassicHttpRequest> reqCap = EasyMock.newCapture();
  5.   EasyMock.expect(
  6.       mockExecChain.proceed(
  7.           EasyMock.capture(reqCap),
  8.           EasyMock.isA(ExecChain.Scope.class))).andReturn(originResponse);
  9.   replayMocks();
  10.   execute(request);
  11.   verifyMocks();
  12.   final ClassicHttpRequest forwarded = reqCap.getValue();
  13.   Assert.assertNull(forwarded.getFirstHeader("Max-Forwards"));
  14. }

代码示例来源：origin: apache/httpcomponents-client

  1. @Test
  2. public void testProperlyFormattedViaHeaderIsAddedToRequests() throws Exception {
  3.   final Capture<ClassicHttpRequest> cap = EasyMock.newCapture();
  4.   request.removeHeaders("Via");
  5.   EasyMock.expect(
  6.       mockExecChain.proceed(
  7.           EasyMock.capture(cap),
  8.           EasyMock.isA(ExecChain.Scope.class))).andReturn(originResponse);
  9.   replayMocks();
  10.   execute(request);
  11.   verifyMocks();
  12.   final ClassicHttpRequest captured = cap.getValue();
  13.   final String via = captured.getFirstHeader("Via").getValue();
  14.   assertValidViaHeader(via);
  15. }

代码示例来源：origin: apache/httpcomponents-client

  1. @Test
  2. public void testDecrementsMaxForwardsWhenForwardingOPTIONSRequest() throws Exception {
  3.   request = new BasicClassicHttpRequest("OPTIONS", "*");
  4.   request.setHeader("Max-Forwards", "7");
  5.   final Capture<ClassicHttpRequest> cap = EasyMock.newCapture();
  6.   EasyMock.expect(
  7.       mockExecChain.proceed(
  8.           EasyMock.capture(cap),
  9.           EasyMock.isA(ExecChain.Scope.class))).andReturn(originResponse);
  10.   replayMocks();
  11.   execute(request);
  12.   verifyMocks();
  13.   final ClassicHttpRequest captured = cap.getValue();
  14.   Assert.assertEquals("6", captured.getFirstHeader("Max-Forwards").getValue());
  15. }

代码示例来源：origin: apache/httpcomponents-client

  1. private void testDoesNotModifyHeaderOnRequest(final String header, final String value) throws Exception {
  2.   final BasicClassicHttpRequest req = new BasicClassicHttpRequest("POST","/");
  3.   req.setEntity(HttpTestUtils.makeBody(128));
  4.   req.setHeader("Content-Length","128");
  5.   req.setHeader(header,value);
  6.   final Capture<ClassicHttpRequest> cap = EasyMock.newCapture();
  7.   EasyMock.expect(
  8.       mockExecChain.proceed(
  9.           EasyMock.capture(cap),
  10.           EasyMock.isA(ExecChain.Scope.class))).andReturn(originResponse);
  11.   replayMocks();
  12.   execute(req);
  13.   verifyMocks();
  14.   final ClassicHttpRequest captured = cap.getValue();
  15.   Assert.assertEquals(value, captured.getFirstHeader(header).getValue());
  16. }

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

EasyMock

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    EasyMock类方法

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