Krakatoa-Earth
/
ProxySystem
3
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

mongodb document subscriber

master
alex 2022-04-11 22:33:26 +02:00
parent d1644689a9
commit f93e0bc684
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/net/krakatoa/proxy/listener/PlayerDisconnectListener.java
View File

@ -37,7 +37,7 @@ public class PlayerDisconnectListener implements Listener {
.getPlayersCollection() .getPlayersCollection()
.find(Filters.eq("uuid", uuid)).first(); .find(Filters.eq("uuid", uuid)).first();
document.subscribe(new Subscriber<Document>() { document.subscribe(new Subscriber<>() {
@Override @Override
public void onSubscribe(Subscription subscription) { public void onSubscribe(Subscription subscription) {
subscription.request(1); subscription.request(1);

4
src/main/java/net/krakatoa/proxy/listener/PostLoginListener.java
View File

@ -32,7 +32,7 @@ public class PostLoginListener implements Listener {
.getPlayersCollection() .getPlayersCollection()
.find(Filters.eq("uuid", uuid)).first(); .find(Filters.eq("uuid", uuid)).first();
document.subscribe(new Subscriber<Document>() { document.subscribe(new Subscriber<>() {
@Override @Override
public void onSubscribe(Subscription subscription) { public void onSubscribe(Subscription subscription) {
subscription.request(1); subscription.request(1);
@ -40,7 +40,7 @@ public class PostLoginListener implements Listener {
@Override @Override
public void onNext(Document document) { public void onNext(Document document) {
ProxySystem.getInstance().getLogger().info(("Inserted: " + document)); ProxySystem.getInstance().getLogger().info("Inserted: " + document);
} }
@Override @Override