Add concurrency module

Author: tbiyiktas

app/src/main/java/com/example/cleannetkit/CreateTodoActivity.java

@@ -9,7 +9,7 @@
 import com.example.cleannetkit.domain.model.Todo;
 import com.example.cleannetkit.domain.todo.CreateTodoUseCase;
 
-import lib.net.CancellableFuture;
+import lib.concurrent.CancellableFuture;
 import lib.net.HttpException;
 import lib.net.NetworkManager;
 
@@ -24,12 +24,10 @@ public class CreateTodoActivity extends AppCompatActivity {
     private TextView tvStatus;
 
     private CancellableFuture<Todo> future;
-
     @Override
     protected void onCreate(Bundle b) {
         super.onCreate(b);
         setContentView(R.layout.activity_create_todo);
-
         etUserId = findViewById(R.id.etUserId);
         etTitle = findViewById(R.id.etTitle);
         cbCompleted = findViewById(R.id.cbCompleted);
@@ -49,21 +47,24 @@ protected void onCreate(Bundle b) {
             String title = etTitle.getText().toString().trim();
             boolean completed = cbCompleted.isChecked();
 
+
             if (userId == null || title.isEmpty()) {
                 tvStatus.setText("UserId ve Title gerekli.");
                 btnCreate.setEnabled(true);
                 progress.setVisibility(View.GONE);
                 return;
             }
 
-            Todo todo = new Todo( userId, title, completed);
+            Todo todo
+                    = new Todo( userId, title, completed);
 
             NetworkManager nm = MyApplication.getNetworkManager();
             CreateTodoService svc = new CreateTodoService(nm);
 
             future = svc.handle(new CreateTodoUseCase.Command(todo));
             future.thenAccept(created -> {
-                tvStatus.setText("Created ✅ id=" + (created == null ? "-" : created.getId()));
+                tvStatus.setText("Created ✅ id=" + (created == null ?
+                        "-" : created.getId()));
                 btnCreate.setEnabled(true);
                 progress.setVisibility(View.GONE);
             }).exceptionally(ex -> {
@@ -76,7 +77,8 @@ protected void onCreate(Bundle b) {
     }
 
     private void handleErr(Throwable ex) {
-        Throwable cause = (ex.getCause() != null) ? ex.getCause() : ex;
+        Throwable cause = (ex.getCause() != null) ?
+                ex.getCause() : ex;
         if (cause instanceof CancellationException) return;
         if (cause instanceof HttpException) {
             HttpException he = (HttpException) cause;
@@ -87,12 +89,13 @@ private void handleErr(Throwable ex) {
     }
 
     private Integer parseInt(String s) {
-        try { return Integer.parseInt(s); } catch (Exception e) { return null; }
+        try { return Integer.parseInt(s);
+        } catch (Exception e) { return null; }
     }
 
     @Override
     protected void onDestroy() {
         if (future != null) future.cancel(true);
         super.onDestroy();
     }
-}
+}

app/src/main/java/com/example/cleannetkit/DeleteTodoActivity.java

@@ -8,7 +8,7 @@
 import com.example.cleannetkit.application.service.todo.DeleteTodoService;
 import com.example.cleannetkit.domain.todo.DeleteTodoUseCase;
 
-import lib.net.CancellableFuture;
+import lib.concurrent.CancellableFuture;
 import lib.net.HttpException;
 import lib.net.NetworkManager;
 

app/src/main/java/com/example/cleannetkit/GetTodosActivity.java

@@ -20,7 +20,7 @@
 import java.util.List;
 import java.util.concurrent.CancellationException;
 
-import lib.net.CancellableFuture;
+import lib.concurrent.CancellableFuture;
 import lib.net.HttpException;
 import lib.net.NetworkManager;
 

app/src/main/java/com/example/cleannetkit/MainActivity.java

@@ -38,7 +38,7 @@
 import java.util.concurrent.CancellationException;
 import java.util.concurrent.atomic.AtomicInteger;
 
-import lib.net.CancellableFuture;
+import lib.concurrent.CancellableFuture;
 import lib.net.HttpException;
 import lib.net.NetworkManager;
 

app/src/main/java/com/example/cleannetkit/TodoParallelDemoActivity.java

@@ -20,7 +20,7 @@
 import java.util.concurrent.CancellationException;
 import java.util.concurrent.atomic.AtomicInteger;
 
-import lib.net.CancellableFuture;
+import lib.concurrent.CancellableFuture;
 import lib.net.HttpException;
 import lib.net.NetworkManager;
 

app/src/main/java/com/example/cleannetkit/UpdateTodoActivity.java

@@ -11,7 +11,7 @@
 import com.example.cleannetkit.domain.todo.GetTodoUseCase;
 import com.example.cleannetkit.domain.todo.UpdateTodoUseCase;
 
-import lib.net.CancellableFuture;
+import lib.concurrent.CancellableFuture;
 import lib.net.HttpException;
 import lib.net.NetworkManager;
 

app/src/main/java/com/example/cleannetkit/application/api/PostsApi.java

@@ -1,4 +1,3 @@
-// com/example/cleannetkit/application/api/PostsApi.java
 package com.example.cleannetkit.application.api;
 
 import com.example.cleannetkit.data.remote.dto.CommentDto;
@@ -12,8 +11,8 @@
 import java.util.List;
 import java.util.Map;
 
+import lib.concurrent.CancellableFuture;
 import lib.net.ABaseApi;
-import lib.net.CancellableFuture;
 import lib.net.NetworkManager;
 import lib.net.command.ACommand;
 import lib.net.command.DeleteCommand;
@@ -29,8 +28,10 @@ public class PostsApi extends ABaseApi {
     private static final String BASE_URL = "https://jsonplaceholder.typicode.com";
     private static final Gson GSON = new Gson();
 
-    public PostsApi(NetworkManager nm) { super(BASE_URL, nm); }
-    public PostsApi(NetworkManager nm, RequestConfigurator rc) { super(BASE_URL, nm, rc); }
+    public PostsApi(NetworkManager nm) { super(BASE_URL, nm);
+    }
+    public PostsApi(NetworkManager nm, RequestConfigurator rc) { super(BASE_URL, nm, rc);
+    }
 
     /* READ */
     public CancellableFuture<List<PostDto>> getPostsDtoF() {
@@ -97,4 +98,4 @@ public CancellableFuture<Void> deletePostF(int id) {
         ACommand cmd = new DeleteCommand("/posts/" + id, null, null);
         return send(cmd, t);
     }
-}
+}

app/src/main/java/com/example/cleannetkit/application/api/TodoApi.java

@@ -1,4 +1,3 @@
-// com/example/cleannetkit/application/api/TodoApi.java
 package com.example.cleannetkit.application.api;
 
 import com.example.cleannetkit.data.remote.dto.TodoDto;
@@ -11,8 +10,8 @@
 import java.util.List;
 import java.util.Map;
 
+import lib.concurrent.CancellableFuture;
 import lib.net.ABaseApi;
-import lib.net.CancellableFuture;
 import lib.net.NetworkManager;
 import lib.net.command.ACommand;
 import lib.net.command.DeleteCommand;
@@ -22,14 +21,15 @@
 import lib.net.command.PutCommand;
 import lib.net.strategy.RequestConfigurator;
 import lib.net.strategy.retry.PayloadSensitiveRetryPolicy;
-
 public class TodoApi extends ABaseApi {
 
     private static final String BASE_URL = "https://jsonplaceholder.typicode.com";
     private static final Gson GSON = new Gson();
 
-    public TodoApi(NetworkManager nm) { super(BASE_URL, nm); }
-    public TodoApi(NetworkManager nm, RequestConfigurator rc) { super(BASE_URL, nm, rc); }
+    public TodoApi(NetworkManager nm) { super(BASE_URL, nm);
+    }
+    public TodoApi(NetworkManager nm, RequestConfigurator rc) { super(BASE_URL, nm, rc);
+    }
 
     /* READ */
     public CancellableFuture<List<TodoDto>> getTodosDtoF() {
@@ -88,4 +88,4 @@ public CancellableFuture<TodoDto> getTodoByIdDtoF(int id) {
         ACommand cmd = new GetCommand("/todos/" + id, null, null);
         return send(cmd, t);
     }
-}
+}

app/src/main/java/com/example/cleannetkit/application/api/UploadApi.java

@@ -1,4 +1,3 @@
-// com/example/cleannetkit/application/api/UploadApi.java
 package com.example.cleannetkit.application.api;
 
 import com.google.gson.reflect.TypeToken;
@@ -7,19 +6,21 @@
 import java.util.HashMap;
 import java.util.Map;
 
+import lib.concurrent.CancellableFuture;
 import lib.net.ABaseApi;
-import lib.net.CancellableFuture;
 import lib.net.NetworkManager;
 import lib.net.command.MultipartCommand;
 import lib.net.strategy.RequestConfigurator;
 import lib.net.strategy.retry.PayloadSensitiveRetryPolicy;
-
 public class UploadApi extends ABaseApi {
 
-    private static final String BASE_URL = "https://example.com"; // kendi endpoint’in
+    private static final String BASE_URL = "https://example.com";
+    // kendi endpoint’in
 
-    public UploadApi(NetworkManager nm) { super(BASE_URL, nm); }
-    public UploadApi(NetworkManager nm, RequestConfigurator rc) { super(BASE_URL, nm, rc); }
+    public UploadApi(NetworkManager nm) { super(BASE_URL, nm);
+    }
+    public UploadApi(NetworkManager nm, RequestConfigurator rc) { super(BASE_URL, nm, rc);
+    }
 
     public static class UploadResponse {
         public String id;
@@ -28,6 +29,7 @@ public static class UploadResponse {
 
     public CancellableFuture<UploadResponse> uploadProfile(File file,
                                                            Map<String,String> fields,
+
                                                            Map<String,String> headers) {
         Type t = new TypeToken<UploadResponse>() {}.getType();
         MultipartCommand cmd = new MultipartCommand(
@@ -36,20 +38,19 @@ public CancellableFuture<UploadResponse> uploadProfile(File file,
                 toHash(fields),
                 toHashFile("file", file)
         );
-
         long bytes = cmd.estimatePayloadBytes();
         // KURAL: büyük upload’larda retry yok
         cmd.withRetryPolicy(new PayloadSensitiveRetryPolicy(bytes, /*maxRetriesForLarge*/ 0));
-
         return send(cmd, t);
     }
 
     private static HashMap<String,String> toHash(Map<String,String> m){
-        return (m == null || m instanceof HashMap) ? (HashMap<String,String>) m : new HashMap<>(m);
+        return (m == null || m instanceof HashMap) ?
+                (HashMap<String,String>) m : new HashMap<>(m);
     }
     private static HashMap<String,File> toHashFile(String name, File f){
         HashMap<String,File> map = new HashMap<>();
         if (f != null) map.put(name, f);
         return map;
     }
-}
+}

app/src/main/java/com/example/cleannetkit/application/service/posts/CreatePostService.java

@@ -7,7 +7,7 @@
 import com.example.cleannetkit.domain.model.Post;
 import com.example.cleannetkit.domain.posts.CreatePostUseCase;
 
-import lib.net.CancellableFuture;
+import lib.concurrent.CancellableFuture;
 import lib.net.NetworkManager;
 
 public class CreatePostService implements CreatePostUseCase {
@@ -20,4 +20,4 @@ public CancellableFuture<Post> handle(Command command) {
         return api.createPostDtoF(dto)
                 .thenApplyC(PostMapper::toDomain);
     }
-}
+}