diff --git a/build.gradle b/build.gradle index 7883020..438448c 100644 --- a/build.gradle +++ b/build.gradle @@ -5,7 +5,7 @@ buildscript { } } -group 'com.mgabriel' +group 'ch.streamly' apply plugin: 'java' diff --git a/src/main/java/com/mgabriel/chronicle/flux/ChronicleStore.java b/src/main/java/ch/streamly/chronicle/flux/ChronicleStore.java similarity index 99% rename from src/main/java/com/mgabriel/chronicle/flux/ChronicleStore.java rename to src/main/java/ch/streamly/chronicle/flux/ChronicleStore.java index dde0d23..f99f4ea 100644 --- a/src/main/java/com/mgabriel/chronicle/flux/ChronicleStore.java +++ b/src/main/java/ch/streamly/chronicle/flux/ChronicleStore.java @@ -1,4 +1,4 @@ -package com.mgabriel.chronicle.flux; +package ch.streamly.chronicle.flux; import java.io.File; import java.util.function.Function; @@ -6,7 +6,7 @@ import java.util.function.Function; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.mgabriel.chronicle.flux.replay.ReplayFlux; +import ch.streamly.chronicle.flux.replay.ReplayFlux; import net.openhft.chronicle.bytes.BytesIn; import net.openhft.chronicle.queue.ExcerptAppender; import net.openhft.chronicle.queue.ExcerptTailer; diff --git a/src/main/java/com/mgabriel/chronicle/flux/FluxStore.java b/src/main/java/ch/streamly/chronicle/flux/FluxStore.java similarity index 95% rename from src/main/java/com/mgabriel/chronicle/flux/FluxStore.java rename to src/main/java/ch/streamly/chronicle/flux/FluxStore.java index a708cf3..2eac6a2 100644 --- a/src/main/java/com/mgabriel/chronicle/flux/FluxStore.java +++ b/src/main/java/ch/streamly/chronicle/flux/FluxStore.java @@ -1,8 +1,8 @@ -package com.mgabriel.chronicle.flux; +package ch.streamly.chronicle.flux; import java.util.function.Function; -import com.mgabriel.chronicle.flux.replay.ReplayFlux; +import ch.streamly.chronicle.flux.replay.ReplayFlux; import org.reactivestreams.Publisher; import reactor.core.Disposable; import reactor.core.publisher.Flux; diff --git a/src/main/java/com/mgabriel/chronicle/flux/replay/ReplayFlux.java b/src/main/java/ch/streamly/chronicle/flux/replay/ReplayFlux.java similarity index 98% rename from src/main/java/com/mgabriel/chronicle/flux/replay/ReplayFlux.java rename to src/main/java/ch/streamly/chronicle/flux/replay/ReplayFlux.java index 1c9e35e..9344a6a 100644 --- a/src/main/java/com/mgabriel/chronicle/flux/replay/ReplayFlux.java +++ b/src/main/java/ch/streamly/chronicle/flux/replay/ReplayFlux.java @@ -1,4 +1,4 @@ -package com.mgabriel.chronicle.flux.replay; +package ch.streamly.chronicle.flux.replay; import java.time.Duration; import java.util.function.Function; diff --git a/src/main/java/com/mgabriel/chronicle/flux/replay/ReplayInLoop.java b/src/main/java/ch/streamly/chronicle/flux/replay/ReplayInLoop.java similarity index 97% rename from src/main/java/com/mgabriel/chronicle/flux/replay/ReplayInLoop.java rename to src/main/java/ch/streamly/chronicle/flux/replay/ReplayInLoop.java index eeee5f6..2e7cb29 100644 --- a/src/main/java/com/mgabriel/chronicle/flux/replay/ReplayInLoop.java +++ b/src/main/java/ch/streamly/chronicle/flux/replay/ReplayInLoop.java @@ -1,4 +1,4 @@ -package com.mgabriel.chronicle.flux.replay; +package ch.streamly.chronicle.flux.replay; import java.time.Duration; import java.util.concurrent.atomic.AtomicBoolean; diff --git a/src/main/java/com/mgabriel/chronicle/flux/replay/ReplayValue.java b/src/main/java/ch/streamly/chronicle/flux/replay/ReplayValue.java similarity index 89% rename from src/main/java/com/mgabriel/chronicle/flux/replay/ReplayValue.java rename to src/main/java/ch/streamly/chronicle/flux/replay/ReplayValue.java index ef2c5f3..43827c8 100644 --- a/src/main/java/com/mgabriel/chronicle/flux/replay/ReplayValue.java +++ b/src/main/java/ch/streamly/chronicle/flux/replay/ReplayValue.java @@ -1,4 +1,4 @@ -package com.mgabriel.chronicle.flux.replay; +package ch.streamly.chronicle.flux.replay; /** * A value wrapper that indicates if the current value is the first value replayed in the replay loop. diff --git a/src/main/java/com/mgabriel/chronicle/flux/replay/ReplayValueImpl.java b/src/main/java/ch/streamly/chronicle/flux/replay/ReplayValueImpl.java similarity index 96% rename from src/main/java/com/mgabriel/chronicle/flux/replay/ReplayValueImpl.java rename to src/main/java/ch/streamly/chronicle/flux/replay/ReplayValueImpl.java index 486179d..8ad0e43 100644 --- a/src/main/java/com/mgabriel/chronicle/flux/replay/ReplayValueImpl.java +++ b/src/main/java/ch/streamly/chronicle/flux/replay/ReplayValueImpl.java @@ -1,4 +1,4 @@ -package com.mgabriel.chronicle.flux.replay; +package ch.streamly.chronicle.flux.replay; import java.util.Objects; diff --git a/src/main/java/com/mgabriel/chronicle/flux/replay/ReplayWithOriginalTiming.java b/src/main/java/ch/streamly/chronicle/flux/replay/ReplayWithOriginalTiming.java similarity index 98% rename from src/main/java/com/mgabriel/chronicle/flux/replay/ReplayWithOriginalTiming.java rename to src/main/java/ch/streamly/chronicle/flux/replay/ReplayWithOriginalTiming.java index ff662fa..8f161ac 100644 --- a/src/main/java/com/mgabriel/chronicle/flux/replay/ReplayWithOriginalTiming.java +++ b/src/main/java/ch/streamly/chronicle/flux/replay/ReplayWithOriginalTiming.java @@ -1,4 +1,4 @@ -package com.mgabriel.chronicle.flux.replay; +package ch.streamly.chronicle.flux.replay; import static java.time.Duration.ofMillis; diff --git a/src/main/java/com/mgabriel/chronicle/flux/replay/Timed.java b/src/main/java/ch/streamly/chronicle/flux/replay/Timed.java similarity index 75% rename from src/main/java/com/mgabriel/chronicle/flux/replay/Timed.java rename to src/main/java/ch/streamly/chronicle/flux/replay/Timed.java index 0c748f9..25f1e71 100644 --- a/src/main/java/com/mgabriel/chronicle/flux/replay/Timed.java +++ b/src/main/java/ch/streamly/chronicle/flux/replay/Timed.java @@ -1,4 +1,4 @@ -package com.mgabriel.chronicle.flux.replay; +package ch.streamly.chronicle.flux.replay; /** * Wraps a value with its timestamp. diff --git a/src/main/java/com/mgabriel/chronicle/flux/replay/TimedValue.java b/src/main/java/ch/streamly/chronicle/flux/replay/TimedValue.java similarity index 95% rename from src/main/java/com/mgabriel/chronicle/flux/replay/TimedValue.java rename to src/main/java/ch/streamly/chronicle/flux/replay/TimedValue.java index 588e2e0..b828d9c 100644 --- a/src/main/java/com/mgabriel/chronicle/flux/replay/TimedValue.java +++ b/src/main/java/ch/streamly/chronicle/flux/replay/TimedValue.java @@ -1,4 +1,4 @@ -package com.mgabriel.chronicle.flux.replay; +package ch.streamly.chronicle.flux.replay; import java.util.Objects; diff --git a/src/main/java/com/mgabriel/chronicle/flux/replay/ValueToDelay.java b/src/main/java/ch/streamly/chronicle/flux/replay/ValueToDelay.java similarity index 88% rename from src/main/java/com/mgabriel/chronicle/flux/replay/ValueToDelay.java rename to src/main/java/ch/streamly/chronicle/flux/replay/ValueToDelay.java index 2a95fc0..97e45dc 100644 --- a/src/main/java/com/mgabriel/chronicle/flux/replay/ValueToDelay.java +++ b/src/main/java/ch/streamly/chronicle/flux/replay/ValueToDelay.java @@ -1,4 +1,4 @@ -package com.mgabriel.chronicle.flux.replay; +package ch.streamly.chronicle.flux.replay; class ValueToDelay implements WrappedValue { diff --git a/src/main/java/com/mgabriel/chronicle/flux/replay/WrappedValue.java b/src/main/java/ch/streamly/chronicle/flux/replay/WrappedValue.java similarity index 51% rename from src/main/java/com/mgabriel/chronicle/flux/replay/WrappedValue.java rename to src/main/java/ch/streamly/chronicle/flux/replay/WrappedValue.java index a78b3ae..bd51390 100644 --- a/src/main/java/com/mgabriel/chronicle/flux/replay/WrappedValue.java +++ b/src/main/java/ch/streamly/chronicle/flux/replay/WrappedValue.java @@ -1,4 +1,4 @@ -package com.mgabriel.chronicle.flux.replay; +package ch.streamly.chronicle.flux.replay; interface WrappedValue { T value(); diff --git a/src/test/java/com/mgabriel/chronicle/flux/ChronicleStoreTest.java b/src/test/java/ch/streamly/chronicle/flux/ChronicleStoreTest.java similarity index 96% rename from src/test/java/com/mgabriel/chronicle/flux/ChronicleStoreTest.java rename to src/test/java/ch/streamly/chronicle/flux/ChronicleStoreTest.java index 7dc0a83..4766943 100644 --- a/src/test/java/com/mgabriel/chronicle/flux/ChronicleStoreTest.java +++ b/src/test/java/ch/streamly/chronicle/flux/ChronicleStoreTest.java @@ -1,6 +1,6 @@ -package com.mgabriel.chronicle.flux; +package ch.streamly.chronicle.flux; -import static com.mgabriel.chronicle.flux.util.ChronicleStoreCleanup.deleteStoreIfItExists; +import static ch.streamly.chronicle.flux.util.ChronicleStoreCleanup.deleteStoreIfItExists; import static java.time.Duration.ofSeconds; import java.time.Duration; diff --git a/src/test/java/com/mgabriel/chronicle/flux/DummyObject.java b/src/test/java/ch/streamly/chronicle/flux/DummyObject.java similarity index 98% rename from src/test/java/com/mgabriel/chronicle/flux/DummyObject.java rename to src/test/java/ch/streamly/chronicle/flux/DummyObject.java index 5da4b51..832c20d 100644 --- a/src/test/java/com/mgabriel/chronicle/flux/DummyObject.java +++ b/src/test/java/ch/streamly/chronicle/flux/DummyObject.java @@ -1,4 +1,4 @@ -package com.mgabriel.chronicle.flux; +package ch.streamly.chronicle.flux; import java.nio.charset.Charset; import java.util.Objects; diff --git a/src/test/java/com/mgabriel/chronicle/flux/demo/ChronicleStoreDemo.java b/src/test/java/ch/streamly/chronicle/flux/demo/ChronicleStoreDemo.java similarity index 86% rename from src/test/java/com/mgabriel/chronicle/flux/demo/ChronicleStoreDemo.java rename to src/test/java/ch/streamly/chronicle/flux/demo/ChronicleStoreDemo.java index b1c96f5..bc8130b 100644 --- a/src/test/java/com/mgabriel/chronicle/flux/demo/ChronicleStoreDemo.java +++ b/src/test/java/ch/streamly/chronicle/flux/demo/ChronicleStoreDemo.java @@ -1,13 +1,13 @@ -package com.mgabriel.chronicle.flux.demo; +package ch.streamly.chronicle.flux.demo; -import static com.mgabriel.chronicle.flux.util.ChronicleStoreCleanup.deleteStoreIfItExists; +import static ch.streamly.chronicle.flux.util.ChronicleStoreCleanup.deleteStoreIfItExists; import static java.util.concurrent.TimeUnit.SECONDS; import java.time.Duration; import java.time.Instant; -import com.mgabriel.chronicle.flux.ChronicleStore; -import com.mgabriel.chronicle.flux.DummyObject; +import ch.streamly.chronicle.flux.ChronicleStore; +import ch.streamly.chronicle.flux.DummyObject; import reactor.core.Disposable; import reactor.core.publisher.Flux; diff --git a/src/test/java/com/mgabriel/chronicle/flux/demo/ReactiveBuffer.java b/src/test/java/ch/streamly/chronicle/flux/demo/ReactiveBuffer.java similarity index 80% rename from src/test/java/com/mgabriel/chronicle/flux/demo/ReactiveBuffer.java rename to src/test/java/ch/streamly/chronicle/flux/demo/ReactiveBuffer.java index df32613..e20e58a 100644 --- a/src/test/java/com/mgabriel/chronicle/flux/demo/ReactiveBuffer.java +++ b/src/test/java/ch/streamly/chronicle/flux/demo/ReactiveBuffer.java @@ -1,11 +1,11 @@ -package com.mgabriel.chronicle.flux.demo; +package ch.streamly.chronicle.flux.demo; -import static com.mgabriel.chronicle.flux.util.ChronicleStoreCleanup.deleteStoreIfItExists; +import static ch.streamly.chronicle.flux.util.ChronicleStoreCleanup.deleteStoreIfItExists; import java.time.Duration; -import com.mgabriel.chronicle.flux.ChronicleStore; -import com.mgabriel.chronicle.flux.DummyObject; +import ch.streamly.chronicle.flux.ChronicleStore; +import ch.streamly.chronicle.flux.DummyObject; import reactor.core.Disposable; import reactor.core.publisher.Flux; diff --git a/src/test/java/com/mgabriel/chronicle/flux/demo/ReplayFluxDemo.java b/src/test/java/ch/streamly/chronicle/flux/demo/ReplayFluxDemo.java similarity index 84% rename from src/test/java/com/mgabriel/chronicle/flux/demo/ReplayFluxDemo.java rename to src/test/java/ch/streamly/chronicle/flux/demo/ReplayFluxDemo.java index 798964f..d6ae369 100644 --- a/src/test/java/com/mgabriel/chronicle/flux/demo/ReplayFluxDemo.java +++ b/src/test/java/ch/streamly/chronicle/flux/demo/ReplayFluxDemo.java @@ -1,10 +1,10 @@ -package com.mgabriel.chronicle.flux.demo; +package ch.streamly.chronicle.flux.demo; import static java.time.Duration.ofSeconds; import java.time.Instant; -import com.mgabriel.chronicle.flux.replay.ReplayFlux; +import ch.streamly.chronicle.flux.replay.ReplayFlux; import reactor.core.publisher.Flux; class ReplayFluxDemo { diff --git a/src/test/java/com/mgabriel/chronicle/flux/demo/ReplayLoopDemo.java b/src/test/java/ch/streamly/chronicle/flux/demo/ReplayLoopDemo.java similarity index 74% rename from src/test/java/com/mgabriel/chronicle/flux/demo/ReplayLoopDemo.java rename to src/test/java/ch/streamly/chronicle/flux/demo/ReplayLoopDemo.java index 790a0b0..73ca874 100644 --- a/src/test/java/com/mgabriel/chronicle/flux/demo/ReplayLoopDemo.java +++ b/src/test/java/ch/streamly/chronicle/flux/demo/ReplayLoopDemo.java @@ -1,11 +1,11 @@ -package com.mgabriel.chronicle.flux.demo; +package ch.streamly.chronicle.flux.demo; import static java.time.Duration.ofSeconds; import java.time.Instant; -import com.mgabriel.chronicle.flux.replay.ReplayInLoop; -import com.mgabriel.chronicle.flux.replay.ReplayValue; +import ch.streamly.chronicle.flux.replay.ReplayValue; +import ch.streamly.chronicle.flux.replay.ReplayInLoop; import reactor.core.publisher.Flux; class ReplayLoopDemo { diff --git a/src/test/java/com/mgabriel/chronicle/flux/demo/ReplayWithOriginalTimingDemo.java b/src/test/java/ch/streamly/chronicle/flux/demo/ReplayWithOriginalTimingDemo.java similarity index 78% rename from src/test/java/com/mgabriel/chronicle/flux/demo/ReplayWithOriginalTimingDemo.java rename to src/test/java/ch/streamly/chronicle/flux/demo/ReplayWithOriginalTimingDemo.java index 0da88ee..7ac5851 100644 --- a/src/test/java/com/mgabriel/chronicle/flux/demo/ReplayWithOriginalTimingDemo.java +++ b/src/test/java/ch/streamly/chronicle/flux/demo/ReplayWithOriginalTimingDemo.java @@ -1,8 +1,8 @@ -package com.mgabriel.chronicle.flux.demo; +package ch.streamly.chronicle.flux.demo; import java.time.Instant; -import com.mgabriel.chronicle.flux.replay.ReplayWithOriginalTiming; +import ch.streamly.chronicle.flux.replay.ReplayWithOriginalTiming; import reactor.core.publisher.Flux; class ReplayWithOriginalTimingDemo { diff --git a/src/test/java/com/mgabriel/chronicle/flux/replay/ReplayFluxTest.java b/src/test/java/ch/streamly/chronicle/flux/replay/ReplayFluxTest.java similarity index 98% rename from src/test/java/com/mgabriel/chronicle/flux/replay/ReplayFluxTest.java rename to src/test/java/ch/streamly/chronicle/flux/replay/ReplayFluxTest.java index 16befff..727d99f 100644 --- a/src/test/java/com/mgabriel/chronicle/flux/replay/ReplayFluxTest.java +++ b/src/test/java/ch/streamly/chronicle/flux/replay/ReplayFluxTest.java @@ -1,4 +1,4 @@ -package com.mgabriel.chronicle.flux.replay; +package ch.streamly.chronicle.flux.replay; import static java.time.Duration.ofMillis; import static java.time.Duration.ofSeconds; @@ -11,7 +11,7 @@ import org.junit.jupiter.api.Assertions; import org.junit.jupiter.api.DisplayName; import org.junit.jupiter.api.Test; -import com.mgabriel.chronicle.flux.DummyObject; +import ch.streamly.chronicle.flux.DummyObject; import reactor.core.Scannable; import reactor.core.publisher.Flux; import reactor.test.StepVerifier; diff --git a/src/test/java/com/mgabriel/chronicle/flux/replay/ReplayValueImplTest.java b/src/test/java/ch/streamly/chronicle/flux/replay/ReplayValueImplTest.java similarity index 96% rename from src/test/java/com/mgabriel/chronicle/flux/replay/ReplayValueImplTest.java rename to src/test/java/ch/streamly/chronicle/flux/replay/ReplayValueImplTest.java index dc53479..906b0d3 100644 --- a/src/test/java/com/mgabriel/chronicle/flux/replay/ReplayValueImplTest.java +++ b/src/test/java/ch/streamly/chronicle/flux/replay/ReplayValueImplTest.java @@ -1,4 +1,4 @@ -package com.mgabriel.chronicle.flux.replay; +package ch.streamly.chronicle.flux.replay; import static org.junit.jupiter.api.Assertions.*; diff --git a/src/test/java/com/mgabriel/chronicle/flux/replay/TimedValueTest.java b/src/test/java/ch/streamly/chronicle/flux/replay/TimedValueTest.java similarity index 96% rename from src/test/java/com/mgabriel/chronicle/flux/replay/TimedValueTest.java rename to src/test/java/ch/streamly/chronicle/flux/replay/TimedValueTest.java index aabf35a..7a90932 100644 --- a/src/test/java/com/mgabriel/chronicle/flux/replay/TimedValueTest.java +++ b/src/test/java/ch/streamly/chronicle/flux/replay/TimedValueTest.java @@ -1,4 +1,4 @@ -package com.mgabriel.chronicle.flux.replay; +package ch.streamly.chronicle.flux.replay; import static org.junit.jupiter.api.Assertions.assertEquals; import static org.junit.jupiter.api.Assertions.assertNotEquals; diff --git a/src/test/java/com/mgabriel/chronicle/flux/util/ChronicleStoreCleanup.java b/src/test/java/ch/streamly/chronicle/flux/util/ChronicleStoreCleanup.java similarity index 95% rename from src/test/java/com/mgabriel/chronicle/flux/util/ChronicleStoreCleanup.java rename to src/test/java/ch/streamly/chronicle/flux/util/ChronicleStoreCleanup.java index 35d6fc8..82be1ec 100644 --- a/src/test/java/com/mgabriel/chronicle/flux/util/ChronicleStoreCleanup.java +++ b/src/test/java/ch/streamly/chronicle/flux/util/ChronicleStoreCleanup.java @@ -1,4 +1,4 @@ -package com.mgabriel.chronicle.flux.util; +package ch.streamly.chronicle.flux.util; import java.io.File; import java.io.IOException;