Merge pull request #80 from cleishm/coroutine-no-experimental

 Move classes using coroutines out of experimental

.gitignore

@@ -9,7 +9,8 @@
 .classpath
 .externalToolBuilders/
 .gradle/
-.idea/
+.idea/*
+!.idea/codeStyles/
 .loadpath
 .metadata
 .prefs

eth-reference-tests/src/test/java/net/consensys/cava/eth/reference/MerkleTrieTestSuite.java

@@ -18,14 +18,13 @@
 import net.consensys.cava.bytes.Bytes;
 import net.consensys.cava.io.Resources;
 import net.consensys.cava.junit.BouncyCastleExtension;
-import net.consensys.cava.trie.experimental.MerklePatriciaTrie;
+import net.consensys.cava.trie.MerklePatriciaTrie;
 
 import java.io.IOException;
 import java.io.InputStream;
 import java.io.UncheckedIOException;
 import java.util.List;
 import java.util.Map;
-import java.util.function.Function;
 import java.util.stream.Stream;
 
 import com.fasterxml.jackson.databind.ObjectMapper;
@@ -50,7 +49,7 @@ private Bytes readFromString(String value) {
   @MethodSource("readAnyOrderTrieTests")
   @SuppressWarnings({"unchecked", "rawtypes"})
   void testAnyOrderTrieTrees(String name, Map input, String root) throws Exception {
-    MerklePatriciaTrie<String> trie = new MerklePatriciaTrie<>((Function<String, Bytes>) this::readFromString);
+    MerklePatriciaTrie<String> trie = MerklePatriciaTrie.create(this::readFromString);
     for (Object entry : input.entrySet()) {
       Map.Entry keyValue = (Map.Entry) entry;
       trie.putAsync(readFromString((String) keyValue.getKey()), (String) keyValue.getValue()).join();
@@ -62,7 +61,7 @@ void testAnyOrderTrieTrees(String name, Map input, String root) throws Exception
   @MethodSource("readTrieTests")
   @SuppressWarnings({"unchecked", "rawtypes"})
   void testTrieTrees(String name, List input, String root) throws Exception {
-    MerklePatriciaTrie<String> trie = new MerklePatriciaTrie<>((Function<String, Bytes>) this::readFromString);
+    MerklePatriciaTrie<String> trie = MerklePatriciaTrie.create(this::readFromString);
     for (Object entry : input) {
       List keyValue = (List) entry;
       trie.putAsync(readFromString((String) keyValue.get(0)), (String) keyValue.get(1)).join();

gradle.properties

@@ -0,0 +1 @@
+kotlin.code.style=official

kv/src/main/kotlin/net/consensys/cava/kv/experimental/KeyValueStore.kt → kv/src/main/kotlin/net/consensys/cava/kv/KeyValueStore.kt

@@ -10,7 +10,7 @@
  * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
  * specific language governing permissions and limitations under the License.
  */
-package net.consensys.cava.kv.experimental
+package net.consensys.cava.kv
 
 import kotlinx.coroutines.CoroutineDispatcher
 import kotlinx.coroutines.Dispatchers
@@ -20,13 +20,12 @@ import net.consensys.cava.concurrent.AsyncCompletion
 import net.consensys.cava.concurrent.AsyncResult
 import net.consensys.cava.concurrent.coroutines.asyncCompletion
 import net.consensys.cava.concurrent.coroutines.asyncResult
+import java.io.Closeable
 
 /**
  * A key-value store.
- *
- * This interface extends [net.consensys.cava.kv.KeyValueStore], exposing co-routine based access methods.
  */
-interface KeyValueStore : net.consensys.cava.kv.KeyValueStore {
+interface KeyValueStore : Closeable {
 
   /**
    * Retrieves data from the store.
@@ -43,7 +42,7 @@ interface KeyValueStore : net.consensys.cava.kv.KeyValueStore {
    * @return An [AsyncResult] that will complete with the stored content,
    *         or an empty optional if no content was available.
    */
-  override fun getAsync(key: Bytes): AsyncResult<Bytes?> = getAsync(Dispatchers.Default, key)
+  fun getAsync(key: Bytes): AsyncResult<Bytes?> = getAsync(Dispatchers.Default, key)
 
   /**
    * Retrieves data from the store.
@@ -74,7 +73,7 @@ interface KeyValueStore : net.consensys.cava.kv.KeyValueStore {
    * @param value The data to store.
    * @return An [AsyncCompletion] that will complete when the content is stored.
    */
-  override fun putAsync(key: Bytes, value: Bytes): AsyncCompletion = putAsync(Dispatchers.Default, key, value)
+  fun putAsync(key: Bytes, value: Bytes): AsyncCompletion = putAsync(Dispatchers.Default, key, value)
 
   /**
    * Puts data into the store.