2 * Copyright (c) 1995-2015, Index Data
4 * See the file LICENSE for details.
8 import java.util.ArrayList;
10 import org.yaz4j.jni.SWIGTYPE_p_p_ZOOM_connection_p;
11 import static org.yaz4j.jni.yaz4jlib.*;
12 import static java.lang.System.out;
18 public class AsyncConnections {
19 private List<AsyncConnection> conns = new ArrayList<AsyncConnection>();
21 public void add(AsyncConnection conn) {
26 SWIGTYPE_p_p_ZOOM_connection_p c_conns = new_zoomConnectionArray(conns.size());
28 for (int i=0; i<conns.size(); i++) {
29 Connection conn = conns.get(i);
30 zoomConnectionArray_setitem(c_conns, i, conn.zoomConnection);
33 while ((ret = ZOOM_event(conns.size(), c_conns)) != 0) {
35 int last = ZOOM_connection_last_event(zoomConnectionArray_getitem(c_conns, idx));
36 AsyncConnection conn = conns.get(idx);
37 String event = ZOOM_get_event_str(last);
38 out.println("Received event " + event + " on connection #"+idx);
40 case ZOOM_EVENT_RECV_SEARCH: conn.handleSearch(); break;
41 case ZOOM_EVENT_RECV_RECORD: conn.handleRecord(); break;
42 //TODO this will make handle error twice
43 case ZOOM_EVENT_END: conn.handleError(); break;
44 //TODO should we simply handle error for any event?
48 delete_zoomConnectionArray(c_conns);