org.easymock.Capture.getValue()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(16.9k)|赞(0)|评价(0)|浏览(103)

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

Capture.getValue介绍

[英]Return captured value
[中]返回捕获的值

代码示例

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

  1. @Test
  2. public void testGetProjectWithOptions() {
  3.  EasyMock.reset(batchMock);
  4.  Capture<RpcBatch.Callback<Project>> callback = Capture.newInstance();
  5.  Capture<Map<DnsRpc.Option, Object>> capturedOptions = Capture.newInstance();
  6.  batchMock.addGetProject(EasyMock.capture(callback), EasyMock.capture(capturedOptions));
  7.  EasyMock.replay(batchMock);
  8.  DnsBatchResult<ProjectInfo> batchResult = dnsBatch.getProject(PROJECT_FIELDS);
  9.  assertNotNull(callback.getValue());
  10.  String selector = (String) capturedOptions.getValue().get(PROJECT_FIELDS.getRpcOption());
  11.  assertTrue(selector.contains(Dns.ProjectField.QUOTA.getSelector()));
  12.  assertTrue(selector.contains(Dns.ProjectField.PROJECT_ID.getSelector()));
  13.  RpcBatch.Callback<Project> capturedCallback = callback.getValue();
  14.  capturedCallback.onSuccess(PROJECT_INFO.toPb());
  15.  assertEquals(PROJECT_INFO, batchResult.get());
  16. }

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

  1. @Test
  2. public void testCopyToBucket() throws Exception {
  3.  initializeExpectedBlob(2);
  4.  BlobInfo target = BlobInfo.newBuilder(BlobId.of("bt", "n")).build();
  5.  CopyWriter copyWriter = createMock(CopyWriter.class);
  6.  Capture<CopyRequest> capturedCopyRequest = Capture.newInstance();
  7.  expect(storage.getOptions()).andReturn(mockOptions);
  8.  expect(storage.copy(capture(capturedCopyRequest))).andReturn(copyWriter);
  9.  replay(storage);
  10.  initializeBlob();
  11.  CopyWriter returnedCopyWriter = blob.copyTo("bt");
  12.  assertEquals(copyWriter, returnedCopyWriter);
  13.  assertEquals(capturedCopyRequest.getValue().getSource(), blob.getBlobId());
  14.  assertEquals(capturedCopyRequest.getValue().getTarget(), target);
  15.  assertFalse(capturedCopyRequest.getValue().overrideInfo());
  16.  assertTrue(capturedCopyRequest.getValue().getSourceOptions().isEmpty());
  17.  assertTrue(capturedCopyRequest.getValue().getTargetOptions().isEmpty());
  18. }

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

  1. @Test
  2. public void testDefaultWriteOptionsHasExpectedDefaults() {
  3.  logging.setFlushSeverity(Severity.ERROR);
  4.  Capture<WriteOption> logNameArg = Capture.newInstance();
  5.  Capture<WriteOption> resourceArg = Capture.newInstance();
  6.  logging.write((Iterable<LogEntry>) anyObject(), capture(logNameArg), capture(resourceArg));
  7.  expectLastCall().once();
  8.  replay(logging);
  9.  loggingAppender.start();
  10.  Timestamp timestamp = Timestamp.ofTimeSecondsAndNanos(100000, 0);
  11.  LoggingEvent loggingEvent = createLoggingEvent(Level.ERROR, timestamp.getSeconds());
  12.  loggingAppender.doAppend(loggingEvent);
  13.  assertThat(logNameArg.getValue()).isEqualTo(defaultWriteOptions[0]);
  14.  // TODO(chingor): Fix this test to work on GCE and locally
  15.  // assertThat(resourceArg.getValue()).isEqualTo(defaultWriteOptions[1]);
  16. }

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

  1. @Test
  2. public void testCopyTo() throws Exception {
  3.  initializeExpectedBlob(2);
  4.  BlobInfo target = BlobInfo.newBuilder(BlobId.of("bt", "nt")).build();
  5.  CopyWriter copyWriter = createMock(CopyWriter.class);
  6.  Capture<CopyRequest> capturedCopyRequest = Capture.newInstance();
  7.  expect(storage.getOptions()).andReturn(mockOptions);
  8.  expect(storage.copy(capture(capturedCopyRequest))).andReturn(copyWriter);
  9.  replay(storage);
  10.  initializeBlob();
  11.  CopyWriter returnedCopyWriter = blob.copyTo("bt", "nt");
  12.  assertEquals(copyWriter, returnedCopyWriter);
  13.  assertEquals(capturedCopyRequest.getValue().getSource(), blob.getBlobId());
  14.  assertEquals(capturedCopyRequest.getValue().getTarget(), target);
  15.  assertFalse(capturedCopyRequest.getValue().overrideInfo());
  16.  assertTrue(capturedCopyRequest.getValue().getSourceOptions().isEmpty());
  17.  assertTrue(capturedCopyRequest.getValue().getTargetOptions().isEmpty());
  18. }

代码示例来源：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: 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: 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.  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(false).once();
  12.  EasyMock.replay(lookupCoordinatorManager, request);
  13.  );
  14.  Assert.assertEquals(500, response.getStatus());
  15.  Assert.assertEquals(ImmutableMap.of("error", "Unknown error updating configuration"), response.getEntity());
  16.  Assert.assertTrue(auditInfoCapture.hasCaptured());
  17.  final AuditInfo auditInfo = auditInfoCapture.getValue();
  18.  Assert.assertEquals(author, auditInfo.getAuthor());
  19.  Assert.assertEquals(comment, auditInfo.getComment());
  20.  Assert.assertEquals(ip, auditInfo.getIp());

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

  1. @Test
  2. public void testListZonesWithOptions() {
  3.  Capture<Map<DnsRpc.Option, Object>> capturedOptions = Capture.newInstance();
  4.  EasyMock.expect(dnsRpcMock.listZones(EasyMock.capture(capturedOptions)))
  5.    .andReturn(LIST_RESULT_OF_PB_ZONES);
  6.  EasyMock.replay(dnsRpcMock);
  7.  dns = options.getService(); // creates DnsImpl
  8.  Page<Zone> zonePage = dns.listZones(ZONE_LIST_OPTIONS);
  9.  assertEquals(1, Lists.newArrayList(zonePage.getValues()).size());
  10.  assertEquals(
  11.    new Zone(dns, new ZoneInfo.BuilderImpl(ZONE_INFO)),
  12.    Lists.newArrayList(zonePage.getValues()).get(0));
  13.  Integer size = (Integer) capturedOptions.getValue().get(ZONE_LIST_OPTIONS[0].getRpcOption());
  14.  assertEquals(MAX_SIZE, size);
  15.  String selector = (String) capturedOptions.getValue().get(ZONE_LIST_OPTIONS[1].getRpcOption());
  16.  assertEquals(PAGE_TOKEN, selector);
  17.  selector = (String) capturedOptions.getValue().get(ZONE_LIST_OPTIONS[2].getRpcOption());
  18.  assertTrue(selector.contains(Dns.ZoneField.DESCRIPTION.getSelector()));
  19.  assertTrue(selector.contains(Dns.ZoneField.NAME.getSelector()));
  20.  selector = (String) capturedOptions.getValue().get(ZONE_LIST_OPTIONS[3].getRpcOption());
  21.  assertEquals(DNS_NAME, selector);
  22. }

代码示例来源：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: 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.  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.  )).andThrow(new RuntimeException(errMsg)).once();
  12.  EasyMock.replay(lookupCoordinatorManager, request);
  13.  );
  14.  Assert.assertEquals(500, response.getStatus());
  15.  Assert.assertEquals(ImmutableMap.of("error", errMsg), response.getEntity());
  16.  Assert.assertTrue(auditInfoCapture.hasCaptured());
  17.  final AuditInfo auditInfo = auditInfoCapture.getValue();
  18.  Assert.assertEquals(author, auditInfo.getAuthor());
  19.  Assert.assertEquals(comment, auditInfo.getComment());
  20.  Assert.assertEquals(ip, auditInfo.getIp());

代码示例来源：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: 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. }

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

Capture

相关文章

    查看更多

    热门标签

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

    最新文章

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