Using Flow API from Java, removed Flow from reactive module.

See helidon-io#1220

Javadoc no longer fails the build. See helidon-io#1223 as a follow up issue.

Signed-off-by: Tomas Langer <tomas.langer@oracle.com>

Author: tomas-langer

CHANGELOG.md

@@ -5,6 +5,11 @@ All notable changes to this project will be documented in this file.
 
 This project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## 2.0.0
+### Backward incompatible changes
+#### Common
+- Flow API is now used from `java.util.concurrent.Flow`, Helidon specific `Flow` class is now removed
+
 ## [1.4.0] 
 
 ### Notes

common/common/src/test/java/io/helidon/common/InputStreamHelperTest.java

@@ -16,16 +16,16 @@
 
 package io.helidon.common;
 
+import java.io.ByteArrayInputStream;
+import java.io.IOException;
+import java.io.InputStream;
+
 import org.junit.jupiter.api.Test;
 
 import static org.junit.jupiter.api.Assertions.assertArrayEquals;
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertNotSame;
 
-import java.io.ByteArrayInputStream;
-import java.io.IOException;
-import java.io.InputStream;
-
 /**
  * Unit tests for class {@link InputStreamHelper}.
  *

common/configurable/src/test/java/io/helidon/common/configurable/ScheduledThreadPoolSupplierTest.java

@@ -21,6 +21,7 @@
 import java.util.concurrent.atomic.AtomicReference;
 
 import io.helidon.config.Config;
+
 import org.junit.jupiter.api.BeforeAll;
 import org.junit.jupiter.api.Test;
 

common/http/src/main/java/io/helidon/common/http/Content.java

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2018 Oracle and/or its affiliates. All rights reserved.
+ * Copyright (c) 2018, 2019 Oracle and/or its affiliates. All rights reserved.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -17,11 +17,10 @@
 package io.helidon.common.http;
 
 import java.util.concurrent.CompletionStage;
+import java.util.concurrent.Flow;
 import java.util.function.Function;
 import java.util.function.Predicate;
 
-import io.helidon.common.reactive.Flow;
-
 /**
  * Represents an HTTP entity as a {@link Flow.Publisher publisher} of {@link DataChunk chunks} with specific
  * features.

common/http/src/main/java/io/helidon/common/http/Reader.java

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2018 Oracle and/or its affiliates. All rights reserved.
+ * Copyright (c) 2018, 2019 Oracle and/or its affiliates. All rights reserved.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -17,10 +17,9 @@
 package io.helidon.common.http;
 
 import java.util.concurrent.CompletionStage;
+import java.util.concurrent.Flow;
 import java.util.function.BiFunction;
 
-import io.helidon.common.reactive.Flow;
-
 /**
  * The Reader transforms a {@link DataChunk} publisher into a completion stage of the associated type.
  *

common/http/src/test/java/io/helidon/common/http/AsciiTest.java

@@ -16,12 +16,12 @@
 
 package io.helidon.common.http;
 
+import org.junit.jupiter.api.Test;
+
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertFalse;
 import static org.junit.jupiter.api.Assertions.assertTrue;
 
-import org.junit.jupiter.api.Test;
-
 /**
  * Unit tests for class {@link Ascii}.
  *

common/http/src/test/java/io/helidon/common/http/FormParamsTest.java

@@ -15,19 +15,18 @@
  */
 package io.helidon.common.http;
 
-import io.helidon.common.CollectionsHelper;
-import org.hamcrest.CoreMatchers;
-import org.junit.jupiter.api.Assertions;
+import java.util.List;
+import java.util.Optional;
+
 import org.junit.jupiter.api.Test;
 
-import static org.hamcrest.CoreMatchers.*;
+import static org.hamcrest.CoreMatchers.equalTo;
+import static org.hamcrest.CoreMatchers.hasItem;
+import static org.hamcrest.CoreMatchers.hasItems;
+import static org.hamcrest.CoreMatchers.is;
 import static org.hamcrest.MatcherAssert.assertThat;
 import static org.junit.jupiter.api.Assertions.assertThrows;
 
-
-import java.util.List;
-import java.util.Optional;
-
 public class FormParamsTest {
 
     private static final String KEY1 = "key1";

common/reactive/src/main/java/io/helidon/common/reactive/BaseProcessor.java

@@ -16,13 +16,12 @@
 package io.helidon.common.reactive;
 
 import java.util.concurrent.ExecutionException;
+import java.util.concurrent.Flow.Processor;
+import java.util.concurrent.Flow.Publisher;
+import java.util.concurrent.Flow.Subscriber;
+import java.util.concurrent.Flow.Subscription;
 import java.util.concurrent.atomic.AtomicBoolean;
 
-import io.helidon.common.reactive.Flow.Processor;
-import io.helidon.common.reactive.Flow.Publisher;
-import io.helidon.common.reactive.Flow.Subscriber;
-import io.helidon.common.reactive.Flow.Subscription;
-
 /**
  * A generic processor used for the implementation of {@link Multi} and {@link Single}.
  *

common/reactive/src/main/java/io/helidon/common/reactive/EmptySubscription.java

@@ -15,7 +15,7 @@
  */
 package io.helidon.common.reactive;
 
-import io.helidon.common.reactive.Flow.Subscription;
+import java.util.concurrent.Flow.Subscription;
 
 /**
  * Empty subscription singleton.

common/reactive/src/main/java/io/helidon/common/reactive/FixedItemsPublisher.java

@@ -18,11 +18,11 @@
 import java.util.Collection;
 import java.util.LinkedList;
 import java.util.Queue;
+import java.util.concurrent.Flow;
+import java.util.concurrent.Flow.Publisher;
+import java.util.concurrent.Flow.Subscriber;
 import java.util.concurrent.atomic.AtomicBoolean;
 
-import io.helidon.common.reactive.Flow.Publisher;
-import io.helidon.common.reactive.Flow.Subscriber;
-
 /**
  * Fixed items publisher implementation.
  */