project-reactor

0열

1답변

아래 제공되는 테스트 방법을 쓰고 있습니다. 이 시험은 다음과 같습니다 ` class ScrapedRecipeCache @Autowired constructor(private val cache: RecipeScrapingCacheService, private val recipeService: RecipeService) : Scr

3열

3답변

Spring Boot 2 Reactor Flux API의 각 클라이언트

Java Project ReactorFlux API 용 Angular 4 클라이언트는 어떻게 만듭니 까? 아래 샘플에는 두 개의 API가 있습니다. Mono API; 및 Flux API 둘 다 curl에서 작동합니다. Angular 4 (4.1.2)에서는 Mono API 만 작동합니다. Angular 4를 Flux API와 함께 사용하는 방법에 대한 아이디

0열

1답변

리 액티브 프로그래밍을 통한 공격적인 타임 아웃 사용의 이점

블로킹 세계에서는 빠른 속도로 실패하고 기본 리소스 (섹션 5.1 https://pragprog.com/book/mnee/release-it)를 해제하기 위해 적극적인 타임 아웃을 설정하는 것이 좋습니다. 비동기/비 차단 영역에서 요청은 주 스레드를 차단하지 않으며 추가 처리를 위해 리소스를 즉시 사용할 수 있습니다. 시간 초과는 여전히 필요하지만 적극적인

0열

1답변

io.projectreactor의 위치 : reactor-bom : Bismuth-RC1?

비록 스프링 리엑터 코어 3.1.0.RC1 et.al. is available io.projectreactor : reactor-bom : Bismuth-RC1을 찾을 수 없습니다. 최신 Spring WebFlux로 테스트하고 싶습니다. 어떤 힌트를 주셔서 감사합니다.

0열

1답변

반응기에서 GroupedFlux를 줄입니다.

유형별로 그룹 요소를 원하는 다음 각 그룹을 줄이려는 고유 한 오브젝트 유형을 가진 하나의 플럭스가 있습니다. 여기에이 작업을 수행하는 간단한 코드가 있습니다. Flux<Item> item=Flux.just(new Item("item1"), new Item("item2")); Flux<Item2> item2=Flux.just(new Item2(4.

0열

1답변

소비자와 Flux.generate 및 병렬

나는 간단한 플럭스가 하나의 스레드에서 예상대로 작동 Flux<Long> flux = Flux.generate( AtomicLong::new, (state, sink) -> { long i = state.getAndIncrement(); sink.next(i); if (i == 3) sink

1열

1답변

내가 좋아하는, 1 대 1 작업에 <code>flatMap</code>을 사용하여보고 예 계속 1 대 1 동작

에 대한 Flux.flatMap 대 Flux.map : 내가 을 예상했을 때 Flux.just("a", "b", "c") .flatMap(s -> Mono.just(s.toUpperCase()) 을 Flux.just("a", "b", "c") .map(String::toUpperCase) (참고 : 나는 가입자를 추가하지 않은 알고

3열

1답변

Project Reactor와의 Spring Security 통합

요청 스레드에 바인딩 된 인증에 의존하는 애플리케이션이 있습니다 (예 : 외부 REST 서비스를 호출 할 때 RestTemplate의 요청 인터셉터에 의해 발신 HTTP 헤더에 투명하게 스틱된다). 저는 Project Reactor를 사용하여이 애플리케이션에서 반응 패턴을 학습하고 적용하는 과정에 있으며 REST API 호출을 반응 적으로 만들기 시작했습니

1열

2답변

오류시 관찰 가능한 변경 가입자

오류시 구독자를 변경하는 방법? 데이터베이스에서 차가운 스트림을 사용합니다. 다음 사례를 참조하십시오. return coctailBundleStream .doOnNext(c -> { hostnames.add(c.get(KEY_HOSTNAME)); // [A] sendToOutboundQueue(c.get(KEY_CRED

1열

1답변

Refactor ReactiveCrudRepository.deleteAll(). 블록 (비 차단 코드)

이 코드를 반응 스타일로 리팩토링 할 수 있습니까? userService.deleteAll().then().block(); userService.saveAll(Flux.just(candidate, tech, pm, hr)).then().block(); 나는이 구현은 onNext(…)then(…)의 방법으로 간단하게 할 수 있다고 생각합니다. 고마워요.