Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Update reactor threading #10418

Closed
jaehong-kim opened this issue Oct 17, 2023 · 0 comments
Closed

Update reactor threading #10418

jaehong-kim opened this issue Oct 17, 2023 · 0 comments
Assignees
Milestone

Comments

@jaehong-kim
Copy link
Contributor

Update reactor delay and interval

pinpoint.config

profiler.reactor.trace.delay=true
profiler.reactor.trace.interval=true

Reactor Mono/Flux delay and interval API

	/**
	 * Create a Mono which delays an onNext signal by a given {@link Duration duration}
	 * on a default Scheduler and completes.
	 * If the demand cannot be produced in time, an onError will be signalled instead.
	 * The delay is introduced through the {@link Schedulers#parallel() parallel} default Scheduler.
	 *
	 * <p>
	 * <img class="marble" src="doc-files/marbles/delay.svg" alt="">
	 * <p>
	 * @param duration the duration of the delay
	 *
	 * @return a new {@link Mono}
	 */
	public static Mono<Long> delay(Duration duration) {
		return delay(duration, Schedulers.parallel());
	}
	/**
	 * Create a {@link Flux} that emits long values starting with 0 and incrementing at
	 * specified time intervals on the global timer. The first element is emitted after
	 * an initial delay equal to the {@code period}. If demand is not produced in time,
	 * an onError will be signalled with an {@link Exceptions#isOverflow(Throwable) overflow}
	 * {@code IllegalStateException} detailing the tick that couldn't be emitted.
	 * In normal conditions, the {@link Flux} will never complete.
	 * <p>
	 * Runs on the {@link Schedulers#parallel()} Scheduler.
	 * <p>
	 * <img class="marble" src="doc-files/marbles/interval.svg" alt="">
	 *
	 * @param period the period {@link Duration} between each increment
	 * @return a new {@link Flux} emitting increasing numbers at regular intervals
	 */
	public static Flux<Long> interval(Duration period) {
		return interval(period, Schedulers.parallel());
	}
@jaehong-kim jaehong-kim added this to the 2.6.0 milestone Oct 17, 2023
@jaehong-kim jaehong-kim self-assigned this Oct 17, 2023
jaehong-kim added a commit to jaehong-kim/pinpoint that referenced this issue Oct 17, 2023
jaehong-kim added a commit that referenced this issue Oct 18, 2023
gipyeong-lee pushed a commit to gipyeong-lee/pinpoint that referenced this issue Nov 1, 2023
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

No branches or pull requests

1 participant