Now you can pass an initial listener to not miss the very first queue…

…d alerts.
frostwire · Feb 1, 2016 · 63a4f47 · 63a4f47
1 parent 6203b57
commit 63a4f47
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 7 deletions.
diff --git a/src/main/java/com/frostwire/jlibtorrent/Session.java b/src/main/java/com/frostwire/jlibtorrent/Session.java
@@ -53,7 +53,7 @@ public final class Session extends SessionHandle {
      * @param settings
      * @param logging
      */
-    public Session(SettingsPack settings, boolean logging) {
+    public Session(SettingsPack settings, boolean logging, AlertListener listener) {
         super(createSession(settings, logging));
 
         this.s = (session) super.s;
@@ -63,8 +63,11 @@ public Session(SettingsPack settings, boolean logging) {
 
         this.listeners = new SparseArray<ArrayList<AlertListener>>();
         this.listenerSnapshots = new SparseArray<AlertListener[]>();
-        this.running = true;
+        if (listener != null) {
+            addListener(listener);
+        }
 
+        this.running = true;
         alertsLoop();
 
         for (Pair<String, Integer> router : defaultRouters()) {
@@ -75,7 +78,7 @@ public Session(SettingsPack settings, boolean logging) {
     }
 
     public Session() {
-        this(new SettingsPack(), false);
+        this(new SettingsPack(), false, null);
     }
 
     public session getSwig() {

diff --git a/src/main/java/com/frostwire/jlibtorrent/demo/SessionTest.java b/src/main/java/com/frostwire/jlibtorrent/demo/SessionTest.java
@@ -3,6 +3,7 @@
 import com.frostwire.jlibtorrent.AlertListener;
 import com.frostwire.jlibtorrent.LibTorrent;
 import com.frostwire.jlibtorrent.Session;
+import com.frostwire.jlibtorrent.SettingsPack;
 import com.frostwire.jlibtorrent.alerts.Alert;
 
 /**
@@ -17,9 +18,7 @@ public static void main(String[] args) throws Throwable {
 
         System.out.println("Using libtorrent version: " + LibTorrent.fullVersion());
 
-        final Session s = new Session();
-
-        s.addListener(new AlertListener() {
+        AlertListener l = new AlertListener() {
             @Override
             public int[] types() {
                 return null;
@@ -29,9 +28,13 @@ public int[] types() {
             public void alert(Alert<?> alert) {
                 System.out.println(alert.getType() + " - " + alert.getSwig().what() + " - " + alert.getSwig().message());
             }
-        });
+        };
+
+        Session s = new Session(new SettingsPack(), false, l);
 
         System.out.println("Press ENTER to exit");
         System.in.read();
+
+        s.abort();
     }
 }