1 files changed, 16 insertions, 5 deletions

diff --git a/src/org/gnunet/util/Scheduler.java b/src/org/gnunet/util/Scheduler.java
index 611467e..0ea9e15 100644
--- a/src/org/gnunet/util/Scheduler.java
+++ b/src/org/gnunet/util/Scheduler.java
@@ -391,8 +391,9 @@ public class Scheduler {
 
     private static void addSubscriberTask(Collection<TaskConfiguration> executableTasks,
                                           TaskConfiguration[] subscribers, int eventType) {
-        if (subscribers[eventType] == null)
+        if (subscribers[eventType] == null) {
             return;
+        }
         executableTasks.add(subscribers[eventType]);
         subscribers[eventType].ctx.reasons.add(eventToReason[eventType]);
     }
@@ -570,8 +571,10 @@ public class Scheduler {
 
             ByteBuffer buffer = ByteBuffer.allocate(256);
 
+            boolean quit = false;
+
             try {
-                while (true) {
+                while (!quit) {
                     buffer.clear();
 
                     fileChannel.read(buffer);
@@ -581,17 +584,25 @@ public class Scheduler {
                     pipe.sink().write(buffer);
                 }
             } catch (IOException e) {
-                throw new IOError(e);
+                quit = true;
             }
 
         }
     }
 
-
-    public static FilePipe createFilePipe(File file) {
+    public static FilePipe openFilePipe(File file) {
         FilePipeThread fpt = new FilePipeThread(file);
         fpt.setDaemon(true);
         fpt.start();
         return new FilePipe(fpt);
     }
+
+    public static class AsyncProcess {
+        // getIn, getOut, getErr
+
+    }
+
+    public static AsyncProcess openAsyncProcess(/*...*/) {
+        throw new UnsupportedOperationException("not implemented yet");
+    }
 }