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

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

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

EasyMock.capture介绍

[英]Expect any byte but captures it for later use.
[中]需要任何字节，但捕获它供以后使用。

代码示例

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

  1. @SuppressWarnings("unchecked")
  2. @Test
  3. public void shouldCreateSessionWindowedStreamWithInactiviyGap() {
  4.  EasyMock.expect(groupedStreamMock.windowedBy(EasyMock.capture(sessionWindows))).andReturn(sessionWindowed);
  5.  EasyMock.expect(sessionWindowed.aggregate(same(initializer),
  6.    same(aggregator),
  7.    anyObject(Merger.class),
  8.    same(materialized))).andReturn(null);
  9.  EasyMock.replay(groupedStreamMock, aggregator, sessionWindowed);
  10.  expression.applyAggregate(groupedStreamMock, initializer, aggregator, materialized);
  11.  assertThat(sessionWindows.getValue().inactivityGap(), equalTo(5000L));
  12.  EasyMock.verify(groupedStreamMock);
  13. }

代码示例来源：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: googleapis/google-cloud-java

  1. @Test
  2. public void testGetZoneNotFound() {
  3.  EasyMock.reset(batchMock);
  4.  Capture<RpcBatch.Callback<ManagedZone>> callback = Capture.newInstance();
  5.  Capture<Map<DnsRpc.Option, Object>> capturedOptions = Capture.newInstance();
  6.  batchMock.addGetZone(
  7.    EasyMock.eq(ZONE_NAME), EasyMock.capture(callback), EasyMock.capture(capturedOptions));
  8.  EasyMock.replay(batchMock);
  9.  DnsBatchResult<Zone> batchResult = dnsBatch.getZone(ZONE_NAME);
  10.  assertEquals(0, capturedOptions.getValue().size());
  11.  GoogleJsonError error = new GoogleJsonError();
  12.  error.setCode(404);
  13.  RpcBatch.Callback<ManagedZone> capturedCallback = callback.getValue();
  14.  capturedCallback.onFailure(error);
  15.  assertNull(batchResult.get());
  16. }

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

  1. @Test
  2. public void testReset()
  3. {
  4.  Capture<String> id1 = Capture.newInstance();
  5.  Capture<String> id2 = Capture.newInstance();
  6.  EasyMock.expect(taskMaster.getSupervisorManager()).andReturn(Optional.of(supervisorManager)).times(2);
  7.  EasyMock.expect(supervisorManager.resetSupervisor(EasyMock.capture(id1), EasyMock.anyObject(DataSourceMetadata.class))).andReturn(true);
  8.  EasyMock.expect(supervisorManager.resetSupervisor(EasyMock.capture(id2), EasyMock.anyObject(DataSourceMetadata.class))).andReturn(false);
  9.  replayAll();
  10.  Response response = supervisorResource.reset("my-id");
  11.  Assert.assertEquals(200, response.getStatus());
  12.  Assert.assertEquals(ImmutableMap.of("id", "my-id"), response.getEntity());
  13.  response = supervisorResource.reset("my-id-2");
  14.  Assert.assertEquals(404, response.getStatus());
  15.  Assert.assertEquals("my-id", id1.getValue());
  16.  Assert.assertEquals("my-id-2", id2.getValue());
  17.  verifyAll();
  18.  resetAll();
  19.  EasyMock.expect(taskMaster.getSupervisorManager()).andReturn(Optional.absent());
  20.  replayAll();
  21.  response = supervisorResource.terminate("my-id");
  22.  Assert.assertEquals(503, response.getStatus());
  23.  verifyAll();
  24. }

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

  1. @Test
  2. public void testDeleteZoneOnSuccess() {
  3.  EasyMock.reset(batchMock);
  4.  Capture<RpcBatch.Callback<Void>> callback = Capture.newInstance();
  5.  batchMock.addDeleteZone(EasyMock.eq(ZONE_NAME), EasyMock.capture(callback));
  6.  EasyMock.replay(batchMock);
  7.  DnsBatchResult<Boolean> batchResult = dnsBatch.deleteZone(ZONE_NAME);
  8.  assertNotNull(callback.getValue());
  9.  RpcBatch.Callback<Void> capturedCallback = callback.getValue();
  10.  Void result = null;
  11.  capturedCallback.onSuccess(result);
  12.  assertTrue(batchResult.get());
  13. }

代码示例来源：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: confluentinc/ksql

  1. @SuppressWarnings("unchecked")
  2. @Test
  3. public void shouldGetMergerForSessionWindowsFromUdafAggregator() {
  4.  EasyMock.expect(groupedStreamMock.windowedBy(EasyMock.capture(sessionWindows))).andReturn(sessionWindowed);
  5.  EasyMock.expect(sessionWindowed.aggregate(same(initializer),
  6.    same(aggregator),
  7.    same(merger),
  8.    same(materialized))).andReturn(null);
  9.  EasyMock.expect(aggregator.getMerger()).andReturn(merger);
  10.  EasyMock.replay(groupedStreamMock, aggregator, sessionWindowed);
  11.  expression.applyAggregate(groupedStreamMock, initializer, aggregator, materialized);
  12.  EasyMock.verify(aggregator);
  13. }

代码示例来源：origin: apache/shiro

  1. @Test
  2.   public void testConstructor() {
  3.     WebSecurityManager securityManager = createMock(WebSecurityManager.class);
  4.     FilterChainResolver filterChainResolver = createMock(FilterChainResolver.class);
  5.     ServletContext servletContext = createMock(ServletContext.class);
  7.     Capture<WebGuiceEnvironment> capture = new Capture<WebGuiceEnvironment>();
  8.     servletContext.setAttribute(eq(EnvironmentLoaderListener.ENVIRONMENT_ATTRIBUTE_KEY), and(anyObject(WebGuiceEnvironment.class), capture(capture)));
  10.     replay(servletContext, securityManager, filterChainResolver);
  12.     WebGuiceEnvironment underTest = new WebGuiceEnvironment(filterChainResolver, servletContext, securityManager);
  14.     assertSame(securityManager, underTest.getSecurityManager());
  15.     assertSame(filterChainResolver, underTest.getFilterChainResolver());
  16.     assertSame(securityManager, underTest.getWebSecurityManager());
  17.     assertSame(servletContext, underTest.getServletContext());
  19.     assertSame(underTest, capture.getValue());
  21.     verify(servletContext);
  22.   }
  23. }

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

  1. @Test
  2. public void shouldExitAndDrainIfQueryStopsRunning() throws Exception {
  3.  // Given:
  4.  expect(queryMetadata.isRunning()).andReturn(true).andReturn(false);
  5.  expect(rowQueue.drainTo(capture(drainCapture))).andAnswer(rows("Row1", "Row2", "Row3"));
  6.  createWriter();
  7.  // When:
  8.  writer.write(out);
  9.  // Then:
  10.  final List<String> lines = getOutput(out);
  11.  assertThat(lines, hasItems(
  12.    containsString("Row1"),
  13.    containsString("Row2"),
  14.    containsString("Row3")));
  15. }

代码示例来源：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: googleapis/google-cloud-java

  1. @Test
  2. public void testProjectGetWithOptions() {
  3.  Capture<Map<DnsRpc.Option, Object>> capturedOptions = Capture.newInstance();
  4.  EasyMock.expect(dnsRpcMock.getProject(EasyMock.capture(capturedOptions)))
  5.    .andReturn(PROJECT_INFO.toPb());
  6.  EasyMock.replay(dnsRpcMock);
  7.  dns = options.getService(); // creates DnsImpl
  8.  ProjectInfo projectInfo = dns.getProject(PROJECT_FIELDS);
  9.  String selector = (String) capturedOptions.getValue().get(PROJECT_FIELDS.getRpcOption());
  10.  assertEquals(PROJECT_INFO, projectInfo);
  11.  assertTrue(selector.contains(Dns.ProjectField.QUOTA.getSelector()));
  12.  assertTrue(selector.contains(Dns.ProjectField.PROJECT_ID.getSelector()));
  13. }

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

  1. @Test
  2. public void testFailedNew() throws Exception
  3.  EasyMock.expect(request.getContentType()).andReturn(MediaType.APPLICATION_JSON).once();
  4.  EasyMock.expect(request.getRemoteAddr()).andReturn(ip).once();
  5.  EasyMock.expect(lookupCoordinatorManager.updateLookups(
  6.    EasyMock.eq(SINGLE_TIER_MAP),
  7.    EasyMock.capture(auditInfoCapture)
  8.  )).andReturn(false).once();
  9.  EasyMock.replay(lookupCoordinatorManager, request);
  10.  );
  11.  Assert.assertEquals(500, response.getStatus());
  12.  Assert.assertEquals(ImmutableMap.of("error", "Unknown error updating configuration"), response.getEntity());
  13.  Assert.assertTrue(auditInfoCapture.hasCaptured());
  14.  final AuditInfo auditInfo = auditInfoCapture.getValue();
  15.  Assert.assertEquals(author, auditInfo.getAuthor());
  16.  Assert.assertEquals(comment, auditInfo.getComment());
  17.  Assert.assertEquals(ip, auditInfo.getIp());

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

  1. @Test
  2. public void testExceptionalNew() throws Exception
  3.  EasyMock.expect(request.getContentType()).andReturn(MediaType.APPLICATION_JSON).once();
  4.  EasyMock.expect(request.getRemoteAddr()).andReturn(ip).once();
  5.  EasyMock.expect(lookupCoordinatorManager.updateLookups(
  6.    EasyMock.eq(SINGLE_TIER_MAP),
  7.    EasyMock.capture(auditInfoCapture)
  8.  )).andThrow(new RuntimeException(errMsg)).once();
  9.  EasyMock.replay(lookupCoordinatorManager, request);
  10.  );
  11.  Assert.assertEquals(500, response.getStatus());
  12.  Assert.assertEquals(ImmutableMap.of("error", errMsg), response.getEntity());
  13.  Assert.assertTrue(auditInfoCapture.hasCaptured());
  14.  final AuditInfo auditInfo = auditInfoCapture.getValue();
  15.  Assert.assertEquals(author, auditInfo.getAuthor());
  16.  Assert.assertEquals(comment, auditInfo.getComment());
  17.  Assert.assertEquals(ip, auditInfo.getIp());

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

  1. @Test
  2. public void testCreateImageWithOptions() {
  3.  Capture<Map<ComputeRpc.Option, Object>> capturedOptions = Capture.newInstance();
  4.  EasyMock.expect(computeRpcMock.createImage(eq(IMAGE.toPb()), capture(capturedOptions)))
  5.    .andReturn(globalOperation.toPb());
  6.  EasyMock.replay(computeRpcMock);
  7.  compute = options.getService();
  8.  Operation operation = compute.create(IMAGE, OPERATION_OPTION_FIELDS);
  9.  String selector =
  10.    (String) capturedOptions.getValue().get(OPERATION_OPTION_FIELDS.getRpcOption());
  11.  assertTrue(selector.contains("selfLink"));
  12.  assertTrue(selector.contains("id"));
  13.  assertTrue(selector.contains("description"));
  14.  assertEquals(23, selector.length());
  15.  assertEquals(globalOperation, operation);
  16. }

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

  1. @Test
  2. public void testCreateNetworkWithOptions() {
  3.  Capture<Map<ComputeRpc.Option, Object>> capturedOptions = Capture.newInstance();
  4.  EasyMock.expect(computeRpcMock.createNetwork(eq(NETWORK.toPb()), capture(capturedOptions)))
  5.    .andReturn(globalOperation.toPb());
  6.  EasyMock.replay(computeRpcMock);
  7.  compute = options.getService();
  8.  Operation operation = compute.create(NETWORK, OPERATION_OPTION_FIELDS);
  9.  String selector =
  10.    (String) capturedOptions.getValue().get(OPERATION_OPTION_FIELDS.getRpcOption());
  11.  assertTrue(selector.contains("selfLink"));
  12.  assertTrue(selector.contains("id"));
  13.  assertTrue(selector.contains("description"));
  14.  assertEquals(23, selector.length());
  15.  assertEquals(globalOperation, operation);
  16. }

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

  1. @Test
  2. public void testGetRegionWithSelectedFields() {
  3.  Capture<Map<ComputeRpc.Option, Object>> capturedOptions = Capture.newInstance();
  4.  EasyMock.expect(computeRpcMock.getRegion(eq(REGION_ID.getRegion()), capture(capturedOptions)))
  5.    .andReturn(REGION.toPb());
  6.  EasyMock.replay(computeRpcMock);
  7.  compute = options.getService();
  8.  Region region = compute.getRegion(REGION_ID.getRegion(), REGION_OPTION_FIELDS);
  9.  String selector = (String) capturedOptions.getValue().get(REGION_OPTION_FIELDS.getRpcOption());
  10.  assertTrue(selector.contains("selfLink"));
  11.  assertTrue(selector.contains("id"));
  12.  assertTrue(selector.contains("description"));
  13.  assertEquals(23, selector.length());
  14.  assertEquals(REGION, region);
  15. }

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

  1. @Test
  2. public void testGetZoneWithSelectedFields() {
  3.  Capture<Map<ComputeRpc.Option, Object>> capturedOptions = Capture.newInstance();
  4.  EasyMock.expect(computeRpcMock.getZone(eq(ZONE_ID.getZone()), capture(capturedOptions)))
  5.    .andReturn(ZONE.toPb());
  6.  EasyMock.replay(computeRpcMock);
  7.  compute = options.getService();
  8.  Zone zone = compute.getZone(ZONE_ID.getZone(), ZONE_OPTION_FIELDS);
  9.  String selector = (String) capturedOptions.getValue().get(ZONE_OPTION_FIELDS.getRpcOption());
  10.  assertTrue(selector.contains("selfLink"));
  11.  assertTrue(selector.contains("id"));
  12.  assertTrue(selector.contains("description"));
  13.  assertEquals(23, selector.length());
  14.  assertEquals(ZONE, zone);
  15. }

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

  1. @Test
  2. public void testSimpleNew() throws Exception
  3.  EasyMock.expect(request.getContentType()).andReturn(MediaType.APPLICATION_JSON).once();
  4.  EasyMock.expect(request.getRemoteAddr()).andReturn(ip).once();
  5.  final Capture<AuditInfo> auditInfoCapture = Capture.newInstance();
  6.  final LookupCoordinatorManager lookupCoordinatorManager = EasyMock.createStrictMock(
  7.    LookupCoordinatorManager.class);
  8.  EasyMock.expect(lookupCoordinatorManager.updateLookups(
  9.    EasyMock.eq(SINGLE_TIER_MAP),
  10.    EasyMock.capture(auditInfoCapture)
  11.  )).andReturn(true).once();
  12.  EasyMock.replay(lookupCoordinatorManager, request);
  13.  final LookupCoordinatorResource lookupCoordinatorResource = new LookupCoordinatorResource(
  14.    lookupCoordinatorManager,
  15.  );
  16.  Assert.assertEquals(202, response.getStatus());
  17.  Assert.assertTrue(auditInfoCapture.hasCaptured());
  18.  final AuditInfo auditInfo = auditInfoCapture.getValue();
  19.  Assert.assertEquals(author, auditInfo.getAuthor());
  20.  Assert.assertEquals(comment, auditInfo.getComment());
  21.  Assert.assertEquals(ip, auditInfo.getIp());

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

  1. @Test
  2. public void testDeleteSnapshotWithSelectedFields_Operation() {
  3.  Capture<Map<ComputeRpc.Option, Object>> capturedOptions = Capture.newInstance();
  4.  EasyMock.expect(
  5.      computeRpcMock.deleteSnapshot(eq(SNAPSHOT_ID.getSnapshot()), capture(capturedOptions)))
  6.    .andReturn(globalOperation.toPb());
  7.  EasyMock.replay(computeRpcMock);
  8.  compute = options.getService();
  9.  Operation operation = compute.deleteSnapshot(SNAPSHOT_ID, OPERATION_OPTION_FIELDS);
  10.  String selector =
  11.    (String) capturedOptions.getValue().get(OPERATION_OPTION_FIELDS.getRpcOption());
  12.  assertTrue(selector.contains("selfLink"));
  13.  assertTrue(selector.contains("id"));
  14.  assertTrue(selector.contains("description"));
  15.  assertEquals(23, selector.length());
  16.  assertEquals(globalOperation, operation);
  17. }

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

  1. @Test
  2. public void testCreateGlobalAddressWithOptions() {
  3.  Capture<Map<ComputeRpc.Option, Object>> capturedOptions = Capture.newInstance();
  4.  EasyMock.expect(
  5.      computeRpcMock.createGlobalAddress(eq(GLOBAL_ADDRESS.toPb()), capture(capturedOptions)))
  6.    .andReturn(globalOperation.toPb());
  7.  EasyMock.replay(computeRpcMock);
  8.  compute = options.getService();
  9.  Operation operation = compute.create(GLOBAL_ADDRESS, OPERATION_OPTION_FIELDS);
  10.  String selector =
  11.    (String) capturedOptions.getValue().get(OPERATION_OPTION_FIELDS.getRpcOption());
  12.  assertTrue(selector.contains("selfLink"));
  13.  assertTrue(selector.contains("id"));
  14.  assertTrue(selector.contains("description"));
  15.  assertEquals(23, selector.length());
  16.  assertEquals(globalOperation, operation);
  17. }

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

EasyMock

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    EasyMock类方法

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