package Ġtest Ċ Ċ import Ġorg . slf 4 j . LoggerFactory Ċ import Ġreactor . core . publisher . Flux Ċ import Ġjava . time . LocalDate ĊĊ Ċ class ĠData Initial izr ( val Ġusers : ĠUser Repository ) Ġ{ ĊĠ Ġprivate Ġval Ġlog Ġ= ĠLoggerFactory . getLogger ( Data Initial izr :: class . java ) ĊĊĠ Ġfun Ġinit Data () Ġ{ ĊĠĠĠ Ġlog . info (" start Ġdata Ġinitialization Ġ... ") ĊĊĠĠĠ Ġusers ĊĠĠĠĠĠĠĠ Ġ. delete All () ĊĠĠĠĠĠĠĠ Ġ. then Many ( ĊĠĠĠĠĠĠĠĠĠĠĠ ĠFlux ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. just ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠUser (" Foo ", Ġ" Foo ", ĠLocalDate . now (). minus Days ( 1 )), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠUser (" Bar ", Ġ" Bar ", ĠLocalDate . now (). minus Days ( 1 0 )), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠUser (" B az ", Ġ" B az ", ĠLocalDate . now (). minus Days ( 1 0 0 )) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. flatMap ( users :: save ) ĊĠĠĠĠĠĠĠ Ġ) ĊĠĠĠĠĠĠĠ Ġ. log () ĊĠĠĠĠĠĠĠ Ġ. subscribe ( ĊĠĠĠĠĠĠĠĠĠĠĠ Ġnull , ĊĠĠĠĠĠĠĠĠĠĠĠ Ġnull , ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ{ Ġlog . info (" done Ġusers Ġinitialization ...") Ġ} ĊĠĠĠĠĠĠĠ Ġ) ĊĠ Ġ} Ċ }