Logger 문의

아 강사님께 조언드리려고 했던건 아니였어요 ㅎㅎ강의 정말 잘들었습니다. 혹시나 듣고 계신 교육생에게 전달하고자 남겼습니다. (_ _)

Sinks multicast의 subscribe에 질문있습니다.

@Superpil 님작성자님께서 생각했던 코드가 노출되려면 아래와 같이 작성하면 되더라구요 ColdSequence로 바꾸려면 multicast()메서드 대신 replay()를 사용하면 됩니다. 저도 질문보고 더 공부해보고 싶어서 찾아봤는데 이렇게 하면 되더라구요~~ (사진)참고 코드입니다.@Slf4j public class SinkManyExample03 { public static void main(String[] args) { Sinks.Many unicastSink = Sinks.many() .replay().all(); Flux fluxView = unicastSink.asFlux(); unicastSink.emitNext(1, FAIL_FAST); unicastSink.emitNext(2, FAIL_FAST); fluxView.subscribe(data -> log.info("Subscriber1 {}", data)); fluxView.subscribe(data -> log.info("Subscriber2 {}", data)); unicastSink.emitNext(3, FAIL_FAST); } } 귀찮아서 변수명은 안바꿨네요 ㅋㅋㅋ...

Hot Sequence의 실무예제

2부 강의 기다리고 있습니다~~

다른 분들 참고하세요

선생님이 한명 살리셨습니다 감사합니다.