Chapter 11 code

Author: dineshonjava

.metadata/.log

@@ -0,0 +1,48 @@
+/**
+ * 
+ */
+package com.packt.patterninspring.chapter11.reactivewebapp.repository;
+
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+import com.packt.patterninspring.chapter11.reactivewebapp.model.Account;
+
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+/**
+ * @author Dinesh.Rajput
+ *
+ */
+public class AccountRepositoryImpl implements AccountRepository {
+	
+	private final Map<Long, Account> accountMap = new ConcurrentHashMap<>(); 
+	
+	public AccountRepositoryImpl() {
+        this.accountMap.put(1000l, new Account(1000l, "Dinesh Rajput",  50000l, "Sector-1"));
+        this.accountMap.put(2000l, new Account(2000l, "Anamika Rajput", 60000l, "Sector-2"));
+        this.accountMap.put(3000l, new Account(3000l, "Arnav Rajput",   70000l, "Sector-3"));
+        this.accountMap.put(4000l, new Account(4000l, "Adesh Rajput",   80000l, "Sector-4"));
+    }
+	
+	@Override
+	public Mono<Account> findById(Long id) {
+		return Mono.justOrEmpty(this.accountMap.get(id));
+	}
+
+	@Override
+	public Flux<Account> findAll() {
+		return Flux.fromIterable(this.accountMap.values());
+	}
+
+	@Override
+	public Mono<Void> save(Mono<Account> account) {
+		Mono<Account> accountMono = account.doOnNext(account -> {
+            accountMap.put(account.getId(), account);
+            System.out.format("Saved %s with id %d%n", account, account.getId());
+        });
+        return accountMono.thenEmpty(Mono.empty());
+	}
+
+}

.metadata/.plugins/org.eclipse.core.resources/.history/10/902ba71c84900017184f86cf58ddffc5

@@ -0,0 +1,48 @@
+/**
+ * 
+ */
+package com.packt.patterninspring.chapter11.reactivewebapp.repository;
+
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+import com.packt.patterninspring.chapter11.reactivewebapp.model.Account;
+
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+/**
+ * @author Dinesh.Rajput
+ *
+ */
+public class AccountRepositoryImpl implements AccountRepository {
+	
+	private final Map<Long, Account> accountMap = new ConcurrentHashMap<>(); 
+	
+	public AccountRepositoryImpl() {
+        this.accountMap.put(1000l, new Account(1000l, "Dinesh Rajput",  50000l, "Sector-1"));
+        this.accountMap.put(2000l, new Account(2000l, "Anamika Rajput", 60000l, "Sector-2"));
+        this.accountMap.put(3000l, new Account(3000l, "Arnav Rajput",   70000l, "Sector-3"));
+        this.accountMap.put(4000l, new Account(4000l, "Adesh Rajput",   80000l, "Sector-4"));
+    }
+	
+	@Override
+	public Mono<Account> findById(Long id) {
+		return Mono.justOrEmpty(this.accountMap.get(id));
+	}
+
+	@Override
+	public Flux<Account> findAll() {
+		return Flux.fromIterable(this.accountMap.values());
+	}
+
+	@Override
+	public Mono<Void> save(Mono<Account> account) {
+		Mono<Account> accountMono = accountMap.doOnNext(account -> {
+            accountMap.put(account.getId(), account);
+            System.out.format("Saved %s with id %d%n", account, account.getId());
+        });
+        return accountMono.thenEmpty(Mono.empty());
+	}
+
+}

.metadata/.plugins/org.eclipse.core.resources/.history/10/b03b610c388a00171e30acfba4717df9

@@ -0,0 +1,44 @@
+/**
+ * 
+ */
+package com.packt.patterninspring.chapter11.reactivewebapp.repository;
+
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+import com.packt.patterninspring.chapter11.reactivewebapp.model.Account;
+
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+/**
+ * @author Dinesh.Rajput
+ *
+ */
+public class AccountRepositoryImpl implements AccountRepository {
+	
+	private final Map<Long, Account> accountMap = new ConcurrentHashMap<>(); 
+	
+	public AccountRepositoryImpl() {
+        this.accountMap.put(1000l, new Account(1000l, "Dinesh Rajput",  50000l, "Sector-1"));
+        this.accountMap.put(2000l, new Account(2000l, "Anamika Rajput", 60000l, "Sector-2"));
+        this.accountMap.put(3000l, new Account(3000l, "Arnav Rajput",   70000l, "Sector-3"));
+        this.accountMap.put(4000l, new Account(4000l, "Adesh Rajput",   80000l, "Sector-4"));
+    }
+	
+	@Override
+	public Mono<Account> findById(Long id) {
+		return Mono.justOrEmpty(this.accountMap.get(id));
+	}
+
+	@Override
+	public Flux<Account> findAll() {
+		return Flux.fromIterable(this.accountMap.values());
+	}
+
+	@Override
+	public Mono<Account> save(Mono<Account> account) {
+		return null;
+	}
+
+}

.metadata/.plugins/org.eclipse.core.resources/.history/12/e06732b2648a00171e30acfba4717df9

@@ -0,0 +1,47 @@
+/**
+ * 
+ */
+package com.packt.patterninspring.chapter11.reactivewebapp.repository;
+
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+import com.packt.patterninspring.chapter11.reactivewebapp.model.Account;
+
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+/**
+ * @author Dinesh.Rajput
+ *
+ */
+public class AccountRepositoryImpl implements AccountRepository {
+	
+	private final Map<Integer, Account> accountMap = new ConcurrentHashMap<>(); 
+	
+	public AccountRepositoryImpl() {
+        this.accountMap.put(1000, new Account(1000l, "Dinesh Rajput", 50000l, "Noida"));
+ 
+        this.accountMap.put(2000, new Account(512,
+                "Spring Guru Mug",
+                "Spring Framework Guru Green Cofee Mug",
+                "https://springframework.guru/wp-content/uploads/2015/04/spring_framework_guru_coffee_mug-r11e7694903c348e1a667dfd2f1474d95_x7j54_8byvr_512.jpg",
+                new BigDecimal("11.95")));
+    }
+	
+	@Override
+	public Mono<Account> findById(Long id) {
+		return null;
+	}
+
+	@Override
+	public Flux<Account> findAll() {
+		return null;
+	}
+
+	@Override
+	public Mono<Account> save(Mono<Account> account) {
+		return null;
+	}
+
+}