Initial commit
This commit is contained in:
34
src/main/java/fr/istic/grpc/todo/TodoServiceImpl.java
Normal file
34
src/main/java/fr/istic/grpc/todo/TodoServiceImpl.java
Normal file
@@ -0,0 +1,34 @@
|
||||
package fr.istic.grpc.todo;
|
||||
|
||||
import java.util.concurrent.*;
|
||||
import java.util.concurrent.atomic.*;
|
||||
|
||||
public class TodoServiceImpl extends TodoServiceGrpc.TodoServiceImplBase {
|
||||
|
||||
private final ConcurrentHashMap<String, Todo.TaskResponse> tasks = new ConcurrentHashMap<>();
|
||||
private final AtomicInteger taskId = new AtomicInteger();
|
||||
|
||||
public int generateUniqueTaskId() {
|
||||
return taskId.incrementAndGet();
|
||||
}
|
||||
|
||||
|
||||
/*
|
||||
@Override
|
||||
public void createTask(Todo.CreateTaskRequest request, StreamObserver<Todo.TaskResponse> responseObserver) {
|
||||
// Créer une tâche en générant un identifiant
|
||||
}
|
||||
|
||||
@Override
|
||||
public void listTasks(Todo.ListTasksRequest request, StreamObserver<Todo.ListTasksResponse> responseObserver) {
|
||||
// La réponse est une liste
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteTask(Todo.DeleteTaskRequest request, StreamObserver<Todo.TaskResponse> responseObserver) {
|
||||
// si la tâche existe, on efface, sinon on indique que l'opération est un echec
|
||||
}
|
||||
|
||||
*/
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user