| 121 | } |
| 122 | |
| 123 | public void add(String url, Receiver receiver) throws MalformedURLException, IllegalStateException { |
| 124 | RemoteReader reader = RemoteReader.fromUrl(url); |
| 125 | Task task = new Task(url, this, receiver); |
| 126 | |
| 127 | synchronized (taskQueue) { |
| 128 | if(status != JobStatus.RUNNING) { |
| 129 | throw new IllegalStateException("RemoteReader Job " + (status == JobStatus.CANCELLED ? "cancelled" : "finished")); |
| 130 | } |
| 131 | taskQueue.add(task); |
| 132 | } |
| 133 | |
| 134 | reader.add(task); |
| 135 | } |
| 136 | |
| 137 | public void onTaskDone(Task t) { |
| 138 | boolean notifyJobEnd = false; |