Commits

Breadcrumbs

History for

onmaster

User selector

All users

All time

Commit History

Commits on Jan 10, 2018

• fix #994 Notify lack of request on bufferTimeout

  

  OlegDokuka

  authored and

  smaldini

  committed
  5a4d38f

  Copy full SHA for 5a4d38f

• fix #969 Reimplement FluxBufferWhen and avoid buffer leaks

  

  simonbasle

  authored and

  smaldini

  committed
  90951be

  Copy full SHA for 90951be

Commits on Jan 9, 2018

• Improve documentation of Flux.merge (#1020)

  Show description for 2488d0c
  

  glyn

  authored and

  simonbasle

  committed
  2488d0c

  Copy full SHA for 2488d0c

• Remove confusing Operators#setTerminated

  Show description for da1769c
  simonbasle

  committed
  da1769c

  Copy full SHA for da1769c

• fix #975 windowWhen reimplementation stops retaining windows

  Show description for 953cf13
  simonbasle

  committed
  953cf13

  Copy full SHA for 953cf13

• fix #1017 - windowWhile now replenishes on premature cancel

  Show description for a961a7f
  

  smaldini

  authored and

  simonbasle

  committed
  a961a7f

  Copy full SHA for a961a7f

Commits on Jan 5, 2018

• fix #1010 Provide a MPSC Queue implementation

  Show description for dc1e3e7
  

  OlegDokuka

  authored and

  simonbasle

  committed
  dc1e3e7

  Copy full SHA for dc1e3e7

• bump AssertJ to 3.9.0

  simonbasle

  committed
  69fbde6

  Copy full SHA for 69fbde6

• fix #1004 Materialize Signals also have Context, which are cached

  Show description for b08ba93
  simonbasle

  committed
  b08ba93

  Copy full SHA for b08ba93

• fix #947 Add getContext() to Signal

  Show description for cc69260
  simonbasle

  committed
  cc69260

  Copy full SHA for cc69260

Commits on Jan 3, 2018

• Convert remaining FluxDelaySequence tests to virtual time

  

  Stephane Maldini

  committed
  6858d0d

  Copy full SHA for 6858d0d

• VirtualTimeScheduler: requeue delays + single Worker (#1001)

  Show description for 81f7f2f
  

  smaldini

  authored and

  simonbasle

  committed
  81f7f2f

  Copy full SHA for 81f7f2f

• fix delay sequence random test failure

  

  Stephane Maldini

  committed
  3e4dd18

  Copy full SHA for 3e4dd18

Commits on Jan 2, 2018

• Fix #990 eventual premature termination issue with WorkQueueProcessor

  Show description for 4b2fd19
  smaldini

  authored
  4b2fd19

  Copy full SHA for 4b2fd19

Commits on Jan 1, 2018

• fix #965 Prevent handle sink usage after error/complete

  Show description for 6f1f25f
  

  simonbasle

  authored and

  smaldini

  committed
  6f1f25f

  Copy full SHA for 6f1f25f

• fix #989 Add delaySequence to Flux

  Show description for df640b6
  

  simonbasle

  authored and

  smaldini

  committed
  df640b6

  Copy full SHA for df640b6

Commits on Dec 18, 2017

• fix #985 Prevent NPE when debug mode is activated via command line

  Show description for 75a0ab0
  simonbasle

  committed
  75a0ab0

  Copy full SHA for 75a0ab0

• fix NO-SOURCE in loops test tasks, reduce verbosity of some tests

  Show description for 14d607b
  simonbasle

  committed
  14d607b

  Copy full SHA for 14d607b

Commits on Dec 15, 2017

• fix #986 Add Duration shutdownAndAwait overload, deprecate long based

  simonbasle

  authored
  3f255db

  Copy full SHA for 3f255db

• fix #968 ParallelFlux#composeGroup maintains parallelism()

  Show description for 506c8b4
  simonbasle

  authored
  506c8b4

  Copy full SHA for 506c8b4

Commits on Dec 14, 2017

• fix #980 Don't retain reference to UnicastProcessor subscriber on cancel

  Show description for 5a84a82
  simonbasle

  authored
  5a84a82

  Copy full SHA for 5a84a82

Commits on Nov 30, 2017

• fix #967 If Level is FINE/FINEST, log errors using debug()/trace()

  Show description for 93bdcd7
  

  simonbasle

  authored and

  smaldini

  committed
  93bdcd7

  Copy full SHA for 93bdcd7

Commits on Nov 27, 2017

• fix #951 Protect doFinally against subscribe() throwing

  Show description for 2a127e0
  simonbasle

  authored
  2a127e0

  Copy full SHA for 2a127e0

Commits on Nov 17, 2017

• fix #943 Detect same-thread request in Mono subscribeOn

  Show description for 5e3fd54
  

  OlegDokuka

  authored and

  simonbasle

  committed
  5e3fd54

  Copy full SHA for 5e3fd54

Commits on Nov 15, 2017

• Make WorkQueueProcessor poison flatmap test less flakky (#946)

  simonbasle

  authored
  fcbcba9

  Copy full SHA for fcbcba9

• Fix comment about Context content in test (#950)

  

  naxhh

  authored and

  simonbasle

  committed
  c6f630d

  Copy full SHA for c6f630d

Commits on Nov 14, 2017

• fix #934 Add the `index` operator

  Show description for 2399234
  simonbasle

  authored
  2399234

  Copy full SHA for 2399234

Commits on Nov 13, 2017

• fix #935 Clarify documentation on default instance Schedulers factories

  

  simonbasle

  authored and

  smaldini

  committed
  6c0155b

  Copy full SHA for 6c0155b

• fix #940 Add a single() to Mono that enforces "exactly one" semantics

  simonbasle

  authored
  0302218

  Copy full SHA for 0302218

Commits on Nov 7, 2017

• fix #936 concat[Map]DelayError(veryEnd) delays Callable errors

  Show description for af0cb62
  simonbasle

  authored
  af0cb62

  Copy full SHA for af0cb62

• fix #906 Add Mono#blockOptional (#918)

  Show description for 0ad7976
  simonbasle

  authored
  0ad7976

  Copy full SHA for 0ad7976

Commits on Nov 6, 2017

• Kotlin extension to create a Mono<T> from a Supplier<T> (#929)

  

  Sergio

  authored and

  simonbasle

  committed
  e443bb9

  Copy full SHA for e443bb9

Commits on Nov 2, 2017

• fix #930 Add javadoc for Mono.cache(Duration)

  simonbasle

  committed
  1cd669b

  Copy full SHA for 1cd669b

Commits on Nov 1, 2017

• fix #925 Enrich timeout's TimeoutException message (#928)

  Show description for 5ccdbb2
  simonbasle

  authored
  5ccdbb2

  Copy full SHA for 5ccdbb2

Commits on Oct 30, 2017

• fix #922 Flux.fromStream(Supplier<Stream>) + auto-close Stream

  Show description for 1b300b6
  simonbasle

  committed
  1b300b6

  Copy full SHA for 1b300b6