From f93e0bc684f661fa42fca0ad7e7bc81abca00109 Mon Sep 17 00:00:00 2001
From: alex <alex@roese.dev>
Date: Mon, 11 Apr 2022 22:33:26 +0200
Subject: [PATCH] mongodb document subscriber

---
 .../net/krakatoa/proxy/listener/PlayerDisconnectListener.java | 2 +-
 .../java/net/krakatoa/proxy/listener/PostLoginListener.java   | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/main/java/net/krakatoa/proxy/listener/PlayerDisconnectListener.java b/src/main/java/net/krakatoa/proxy/listener/PlayerDisconnectListener.java
index 42c308e..9b37a91 100755
--- a/src/main/java/net/krakatoa/proxy/listener/PlayerDisconnectListener.java
+++ b/src/main/java/net/krakatoa/proxy/listener/PlayerDisconnectListener.java
@@ -37,7 +37,7 @@ public class PlayerDisconnectListener implements Listener {
         .getPlayersCollection()
         .find(Filters.eq("uuid", uuid)).first();
 
-    document.subscribe(new Subscriber<Document>() {
+    document.subscribe(new Subscriber<>() {
       @Override
       public void onSubscribe(Subscription subscription) {
         subscription.request(1);
diff --git a/src/main/java/net/krakatoa/proxy/listener/PostLoginListener.java b/src/main/java/net/krakatoa/proxy/listener/PostLoginListener.java
index 7e4a5f1..44649fe 100755
--- a/src/main/java/net/krakatoa/proxy/listener/PostLoginListener.java
+++ b/src/main/java/net/krakatoa/proxy/listener/PostLoginListener.java
@@ -32,7 +32,7 @@ public class PostLoginListener implements Listener {
         .getPlayersCollection()
         .find(Filters.eq("uuid", uuid)).first();
 
-    document.subscribe(new Subscriber<Document>() {
+    document.subscribe(new Subscriber<>() {
       @Override
       public void onSubscribe(Subscription subscription) {
         subscription.request(1);
@@ -40,7 +40,7 @@ public class PostLoginListener implements Listener {
 
       @Override
       public void onNext(Document document) {
-        ProxySystem.getInstance().getLogger().info(("Inserted: " + document));
+        ProxySystem.getInstance().getLogger().info("Inserted: " + document);
       }
 
       @Override