tests: Fix client tests

This commit is contained in:
Owain van Brakel
2020-03-27 21:33:56 +01:00
parent 28c742691c
commit 85b17d3bec

View File

@@ -128,12 +128,18 @@ public class PluginManager
this.groups = groups; this.groups = groups;
this.settingsFileInput = config; this.settingsFileInput = config;
eventBus.subscribe(SessionOpen.class, this, this::onSessionOpen); if (eventBus != null)
eventBus.subscribe(SessionClose.class, this, this::onSessionClose); {
eventBus.subscribe(SessionOpen.class, this, this::onSessionOpen);
eventBus.subscribe(SessionClose.class, this, this::onSessionClose);
}
groups.getMessageStringSubject() if (groups != null)
.subscribeOn(Schedulers.from(SwingUtilities::invokeLater)) {
.subscribe(this::receive); groups.getMessageStringSubject()
.subscribeOn(Schedulers.from(SwingUtilities::invokeLater))
.subscribe(this::receive);
}
} }
private void onSessionOpen(SessionOpen event) private void onSessionOpen(SessionOpen event)