添加测试

Author: aping-source

src/main/java/io/github/kavahub/file/writer/AIOFileWriter.java

@@ -1,5 +1,6 @@
 package io.github.kavahub.file.writer;
 
+import java.io.IOException;
 import java.nio.file.Path;
 import java.nio.file.StandardOpenOption;
 import java.util.concurrent.CompletableFuture;
@@ -11,6 +12,14 @@
 @UtilityClass
 @Slf4j
 public class AIOFileWriter {
+    public CompletableFileWriter of(Path file) throws IOException {
+        return of(file, StandardOpenOption.CREATE_NEW, StandardOpenOption.WRITE);
+    }
+
+    public CompletableFileWriter of(Path file, StandardOpenOption... options) throws IOException {
+        return CompletableFileWriter.of(file, options);
+    }
+
     public CompletableFuture<Integer> write(Path file, byte[] bytes) {
         return write(file, bytes, StandardOpenOption.CREATE_NEW, StandardOpenOption.WRITE);
     }

src/test/java/io/github/kavahub/file/AIOFileReaderExample.java renamed to src/test/java/io/github/kavahub/file/AIOFileReaderManualTest.java

@@ -11,7 +11,7 @@
 
 import io.github.kavahub.file.reader.AIOFileReader;
 
-public class AIOFileReaderExample {
+public class AIOFileReaderManualTest {
     @Test
     public void giveFile_whenReadLine_thenPrint() {
         final Path FILE = Paths.get("src", "test", "resources", "fileWithmanyOfLine.txt");

src/test/java/io/github/kavahub/file/AIOFileWriterExample.java renamed to src/test/java/io/github/kavahub/file/AIOFileWriterManualTest.java

@@ -12,7 +12,7 @@
 import io.github.kavahub.file.reader.AIOFileReader;
 import io.github.kavahub.file.writer.AIOFileWriter;
 
-public class AIOFileWriterExample {
+public class AIOFileWriterManualTest {
     private static final Path FILE_TO_WRITE = Paths.get("target", "fileToWrite.txt");
 
     @BeforeEach
@@ -34,9 +34,8 @@ public void whenWriteWithStringSplit() throws IOException {
 
     @Test
     public void whenWriteWithQueryFlatMapMerge() throws IOException {
-        Query<String>  data = Query.of("This is file content：你好")
-            .flatMapMerge(line -> Query.of(line.split(" ")))
-            .map((line) -> line + System.lineSeparator());
+        Query<String> data = Query.of("This is file content：你好").flatMapMerge(line -> Query.of(line.split(" ")))
+                .map((line) -> line + System.lineSeparator());
         AIOFileWriter.write(FILE_TO_WRITE, data).join();
     }
 
@@ -45,14 +44,14 @@ public void whenWriteWithQueryFilter() throws IOException {
         final Path FILE = Paths.get("src", "test", "resources", "fileWithmanyOfLine.txt");
 
         Query<String> reader = AIOFileReader.line(FILE)
-            // 忽略前2行
-            .skip(2)
-            // 过滤掉空行
-            .filter(line -> !line.isBlank())
-            // 转换成大写
-            .map(String::toUpperCase)
-            // 加入换行符
-            .map((line) -> line + System.lineSeparator());
+                // 忽略前2行
+                .skip(2)
+                // 过滤掉空行
+                .filter(line -> !line.isBlank())
+                // 转换成大写
+                .map(String::toUpperCase)
+                // 加入换行符
+                .map((line) -> line + System.lineSeparator());
         AIOFileWriter.write(FILE_TO_WRITE, reader).join();
-    }
+    }        
 }

src/test/java/io/github/kavahub/file/NIOFileLineReaderExample.java renamed to src/test/java/io/github/kavahub/file/NIOFileLineReaderManualTest.java

@@ -10,7 +10,7 @@
 
 import io.github.kavahub.file.reader.NIOFileLineReader;
 
-public class NIOFileLineReaderExample {
+public class NIOFileLineReaderManualTest {
 
 
     @Test

src/test/java/io/github/kavahub/file/SystemInToFileExample.java

@@ -0,0 +1,34 @@
+package io.github.kavahub.file;
+
+import java.io.IOException;
+import java.nio.file.Paths;
+import java.util.Scanner;
+
+import io.github.kavahub.file.writer.AIOFileWriter;
+import io.github.kavahub.file.writer.CompletableFileWriter;
+
+public class SystemInToFileExample {
+    
+    public static void main(String[] arg) throws IOException {
+        // 异步写入文件
+        CompletableFileWriter writer = AIOFileWriter.of(Paths.get("systemIn.txt"));
+
+        try (Scanner scanner = new Scanner(System.in)) {
+            while (scanner.hasNext()) {
+                String line = scanner.next();
+                if ("bye".equals(line)) {
+                    break;
+                }
+                writer.write(line + System.lineSeparator());
+            }
+
+            writer.getPosition().whenComplete((size, error) -> {
+                if (error != null) {
+                    error.printStackTrace();
+                }
+
+                System.out.println("输入字节数：" + size);
+            });
+        }
+    }
+}