private void setupListeningForAccount()

in service/src/main/java/org/apache/fineract/cn/stellarbridge/service/internal/horizonadapter/HorizonServerPaymentObserver.java [75:87]

11 lines of code
1 McCabe index (conditional complexity)


  private void setupListeningForAccount(
      @NotNull final StellarAccountId stellarAccountId, @NotNull final Optional<String> cursor)
  {
    logger.info("HorizonServerPaymentObserver.setupListeningForAccount {}, cursor {}",
        stellarAccountId.getPublicKey(), cursor);

    final EffectsRequestBuilder effectsRequestBuilder
        = new EffectsRequestBuilder(URI.create(stellarBridgeProperties.getHorizonAddress()));
    effectsRequestBuilder.forAccount(KeyPair.fromAccountId(stellarAccountId.getPublicKey()));
    cursor.ifPresent(effectsRequestBuilder::cursor);

    effectsRequestBuilder.stream(listener);
  }