reactive 프로그래밍에서 순차적 코드 실행에 대해 질문드립니다.

Question

Spring Cloud Gateway를 사용하게 되어 reactive programming에 공부하며 코드를 작성하고 있습니다.아래의 코드를 실행시키면 subscribe 안에서 requestBody 받아온 값이 제대로 출력되지만, 현재 코드에서는 return이 먼저 되고 subscribe가 진행되어 함수 호출한 뒤 return값으로 requestBody를 사용할 수 없는 상황입니다. 이 코드에서 subscribe가 진행된 뒤 return을 하는 순서대로 진행하고 싶다면 어떻게 코드를 작성해야 할지 조언 구합니다..private String resolveBodyFromRequest(ServerHttpRequest request){ String requestBody; //Get the request body request.getBody().concatMap(dataBuffer -> { System.out.println(&#34;Thread - &#34; &#43; Thread.currentThread().getName() &#43; &#34;: readable count is &#34; &#43; dataBuffer.readableByteCount()); byte[] bytes &#61; new byte[dataBuffer.readableByteCount()]; //readableByteCount: 이 버퍼에서 읽을 수 있는 바이트 수 반환-> 버퍼 크기 만큼의 바이트 배열 생성 dataBuffer.read(bytes); DataBufferUtils.release(dataBuffer); return Mono.just(bytes); }).subscribe( s -> { requestBody &#61; new String(s); System.out.println(requestBody); } ); System.out.println(requestBody); //1 return requestBody ; }

reactive 프로그래밍에서 순차적 코드 실행에 대해 질문드립니다.

0개의 답변

#rxjava 목록