reactor/reactor-core

Issues

• `FluxBuffer` hangs when buffer Supplier returns a Set

  #3821 opened 10 days ago by Sage-Pierce
  0

• Monospace not rendered correctly in Antora Example titles

  #3813 opened 25 days ago by pderop
  0

• Enabled Automatic Context Propagation and context propagation with lift causes ClassCastException

  #3762 opened a month ago by kz-dt
  10

• Redirect old docs links to new Antora docs links

  #3812 opened 25 days ago by pderop
  0

• Example titles are not prefixed with Example N.

  #3811 opened a month ago by pderop
  0

• Failing while building reactor-core version 3.4.18 using ./gradlew build (io.projectreactor:reactor-core:3.4.18)

  #3803 opened a month ago by shivsrivastava
  4

• autoConnect(0) seems to be broken - late subscribers receive data

  #3805 opened a month ago by kitkars
  0

• Flux.mergeSequential does not subscribe to last Producer in specific circumstances

  #3802 opened a month ago by jmmerz
  1

• Fatal exceptions not caught in onErrorDropped Hook

  #3804 opened a month ago by ResoluteError
  2

• Javadoc for some versions is missing from the website

  #3794 opened 2 months ago by dkhalanskyjb
  3

• add `@Incubating` annotation

  #3647 opened 2 months ago by OlegDokuka
  4

• Auto-cancelled Sink still accepts emissions

  #3715 opened 4 months ago by kaqqao
  9

• Support Considering Individual Element Weight in Determining Buffer Boundary instead of Element Counts

  #3786 opened 2 months ago by moksie
  0

• Too difficult to control how much Reactor buffers internally

  #3759 opened 3 months ago by RonBarkan
  2

• thenMany does not ignore all emissions of a concat due to incorrect optimization

  #3777 opened 2 months ago by stefnoten-aca
  2

• BoundedElasticThreadPerTaskSchedulerTest > ensuresTasksScheduling() FAILED

  #3772 opened 2 months ago by chemicL
  4

• TimedScheduler leaks cancelled pending task samples

  #3697 opened 2 months ago by nathankooij
  6

• FluxBufferWhenTest > timedOutBuffersDontLeak() FAILED

  #3782 opened 2 months ago by chemicL
  0

• Flaky test - FluxBlackboxProcessorVerification

  #3742 opened 3 months ago by chemicL
  6

• Add bufferWeightedWithin operator.

  #3774 opened 3 months ago by He-Pin
  0

• Flaky test - DefaultTestSubscriberTest

  #3749 opened 3 months ago by chemicL
  5

• SinksTest > OptimisticEmitFailureHandlerTest > shouldRetryOptimistically() FAILED

  #3773 opened 3 months ago by chemicL
  0

• BufferTimeoutSubscriber is not thread safe

  #3738 opened 3 months ago by jamiestewart
  2

• [Flaky test] FluxCreateTest.fluxCreateOnRequestMultipleThreadsSlowProducer

  #3765 opened 3 months ago by chemicL
  0

• CompletableFuture.whenComplete is not invoked for some requests

  #3735 opened 3 months ago by rohitrajwani
  11

• [test] Verify Initialization of Default Labels

  #3756 opened 3 months ago by pderop
  0

• context lost when using Mono.create with threads

  #3752 opened 3 months ago by weditor
  2

• Mono.share() allow a stream to be canceled

  #3740 opened 3 months ago by rgarciapariente
  5

• Empty hot source hangs with 2nd late subscriber

  #3739 opened 3 months ago by RonBarkan
  4

• Timeout behavior in Mono.block(timeout)

  #3709 opened 3 months ago by ferrerogg
  4

• Flux/Mono.usingWhen late resource memory leak

  #3695 opened 3 months ago by mlozbin
  14

• Flux share method feature

  #3731 opened 4 months ago by Nuclear-Liu
  2

• Weird behavior of Sinks.many().multicast() with retryWhen

  #3708 opened 4 months ago by larousso
  2

• i m having an error "r.core.Exceptions","stack_trace":"java.lang.StackOverflowError: null

  #3726 opened 4 months ago by mehdi-git1
  2

• `Flux#collectList` freezes when I use my own implementation of `Subscriber`

  #3698 opened 4 months ago by rost5000
  2

• FluxSampleTimeout Javadoc concerns

  #3689 opened 5 months ago by MikkelHJuul
  3

• why some steps dont execute during mono

  #3701 opened 5 months ago by lizq15
  1

• HTTP 404 on documentation / Javadoc Link

  #3699 opened 5 months ago by jprinet
  1

• Spring Boot 3 webflux missing tracing information (e.g. traceId)

  #3691 opened 5 months ago by jhengy
  3

• [Enhancement request] Flux from streaming file

  #3656 opened 5 months ago by patpatpat123
  4

• NPE when Mono(List(null)).flatMapIterable

  #3649 opened 7 months ago by Hiosdra
  4

• [Suggestion] Dynamic Concurrency Control in flatMap for External System Calls

  #3652 opened 6 months ago by AChekroun
  3

• onErrorDropped false positive

  #3666 opened 6 months ago by rozza
  3

• PendingTasks leak in TimedScheduler

  #3642 opened 6 months ago by AChekroun
  4

• investigate flacky test reactor.core.publisher.tck.FluxBlackboxProcessorVerification > required_spec313_cancelMustMakeThePublisherEventuallyDropAllReferencesToTheSubscriber

  #3663 opened 6 months ago by violetagg
  1

• OpenTelemetry Agent and Reactor Core explanations

  #3661 opened 6 months ago by almogtavor
  1

• [Suggestion] Create an operator that merges multiple ordered flux's into a single flow with optional fields for flux's with gaps in there keys

  #3645 opened 7 months ago by vibbix
  6

• StepVerifier usecases

  #3653 opened 6 months ago by jmayday
  1

• What's the essence of interface Fuseable?

  #3651 opened 6 months ago by zhanghaolong
  3

• Context being lost between @RabbitListener and Webclient

  #3648 opened 7 months ago by Jojoooo1
  4