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

Zonky.getInvestment介绍

[英]Retrieve investments from user's portfolio via PortfolioApi, in a given order.
[中]

代码示例

代码示例来源：origin: com.github.robozonky/robozonky-app

public Collection<Investment> complement(final Collection<Investment> investments) {
  final Set<Long> idsToComplement = investments.stream().map(Registry::getId).collect(Collectors.toSet());
  return storages.get(Category.NEW).complement(idsToComplement)
      .parallel()
      .mapToObj(id -> tenant.call(z -> z.getInvestment(id)))
      .flatMap(i -> i.map(Stream::of).orElse(Stream.empty()))
      .collect(Collectors.toList());
}

代码示例来源：origin: RoboZonky/robozonky

@Test
void getters() {
  final Zonky z = mockZonky();
  assertSoftly(softly -> {
    softly.assertThat(z.getAvailableLoans(Select.unrestricted())).isEmpty();
    softly.assertThat(z.getBlockedAmounts()).isEmpty();
    softly.assertThat(z.getInvestments(Select.unrestricted())).isEmpty();
    softly.assertThat(z.getInvestment(1)).isEmpty();
    softly.assertThat(z.getDelinquentInvestments()).isEmpty();
    softly.assertThat(z.getAvailableParticipations(Select.unrestricted())).isEmpty();
    softly.assertThat(z.getTransactions(Select.unrestricted())).isEmpty();
    softly.assertThat(z.getDevelopments(1)).isEmpty();
  });
}

代码示例来源：origin: RoboZonky/robozonky

public Collection<Investment> complement(final Collection<Investment> investments) {
  final Set<Long> idsToComplement = investments.stream().map(Registry::getId).collect(Collectors.toSet());
  return storages.get(Category.NEW).complement(idsToComplement)
      .parallel()
      .mapToObj(id -> tenant.call(z -> z.getInvestment(id)))
      .flatMap(i -> i.map(Stream::of).orElse(Stream.empty()))
      .collect(Collectors.toList());
}

代码示例来源：origin: RoboZonky/robozonky

@Test
  void complements() {
    when(zonky.getInvestment(eq(i.getId()))).thenReturn(Optional.of(i));
    final Registry r = new Registry(tenant);
    r.addCategory(i, Category.DEFAULTED);
    r.persist();
    assertThat(r.complement(Collections.emptySet())).containsExactly(i);
    assertThat(r.complement(Collections.singleton(Investment.custom().build()))).containsExactly(i);
    assertThat(r.complement(Collections.singleton(i))).isEmpty();
  }
}

代码示例来源：origin: RoboZonky/robozonky

@Test
  void handlesRepayment() {
    final Investment i1 = Investment.custom().setDaysPastDue(1).build();
    when(zonky.getDelinquentInvestments()).thenReturn(Stream.of(i1));
    // run test
    payload.accept(tenant); // nothing will happen here, as this is the initializing run
    final Investment i2 = Investment.custom().setDaysPastDue(1).setPaymentStatus(PaymentStatus.PAID).build();
    when(zonky.getDelinquentInvestments()).thenReturn(Stream.of(i2));
    when(zonky.getLoan(anyInt())).thenReturn(Loan.custom().build());
    payload.accept(tenant); // the new delinquency will show up now
    assertThat(getEventsRequested()).hasSize(1)
        .extracting(e -> (Object) e.getClass().getInterfaces()[0])
        .containsOnly(LoanNowDelinquentEvent.class);
    readPreexistingEvents();
    // now the same delinquency is no longer available
    when(zonky.getDelinquentInvestments()).thenReturn(Stream.empty());
    when(zonky.getInvestment(eq(i2.getId()))).thenReturn(Optional.of(i2));
    payload.accept(tenant); // nothing happens, repayments are not handled by this class
    assertThat(getEventsRequested()).isEmpty();
  }
}

代码示例来源：origin: RoboZonky/robozonky

@Test
void handlesLoss() {
  final Investment i1 = Investment.custom().setDaysPastDue(1).build();
  when(zonky.getDelinquentInvestments()).thenReturn(Stream.of(i1));
  // run test
  payload.accept(tenant); // nothing will happen here, as this is the initializing run
  final Investment i2 = Investment.custom().setDaysPastDue(1).setPaymentStatus(PaymentStatus.WRITTEN_OFF).build();
  when(zonky.getDelinquentInvestments()).thenReturn(Stream.of(i2));
  when(zonky.getLoan(anyInt())).thenReturn(Loan.custom().build());
  payload.accept(tenant); // the new delinquency will show up now
  assertThat(getEventsRequested()).hasSize(1)
      .extracting(e -> (Object) e.getClass().getInterfaces()[0])
      .containsOnly(LoanNowDelinquentEvent.class);
  readPreexistingEvents();
  // now the same delinquency is no longer available
  when(zonky.getDelinquentInvestments()).thenReturn(Stream.empty());
  when(zonky.getInvestment(eq(i2.getId()))).thenReturn(Optional.of(i2));
  payload.accept(tenant); // the lost loan will show up now
  assertThat(getEventsRequested()).hasSize(1)
      .first()
      .isInstanceOf(LoanLostEvent.class);
}

代码示例来源：origin: RoboZonky/robozonky

@Test
void handlesRegularHealing() {
  final Investment i1 = Investment.custom().setDaysPastDue(1).build();
  when(zonky.getDelinquentInvestments()).thenReturn(Stream.of(i1));
  // run test
  payload.accept(tenant); // nothing will happen here, as this is the initializing run
  final Investment i2 = Investment.custom().setDaysPastDue(1).setPaymentStatus(PaymentStatus.OK).build();
  when(zonky.getDelinquentInvestments()).thenReturn(Stream.of(i2));
  when(zonky.getLoan(anyInt())).thenReturn(Loan.custom().build());
  payload.accept(tenant); // the new delinquency will show up now
  assertThat(getEventsRequested()).hasSize(1)
      .extracting(e -> (Object) e.getClass().getInterfaces()[0])
      .containsOnly(LoanNowDelinquentEvent.class);
  readPreexistingEvents();
  // now the same delinquency is no longer available
  when(zonky.getDelinquentInvestments()).thenReturn(Stream.empty());
  when(zonky.getInvestment(eq(i2.getId()))).thenReturn(Optional.of(i2));
  payload.accept(tenant); // the new delinquency will show up now
  assertThat(getEventsRequested()).hasSize(1)
      .first()
      .isInstanceOf(LoanNoLongerDelinquentEvent.class);
}