166167168169170171172
* one element at a time, with peekSet method. */ public abstract TSet readSetBegin() throws TException; public boolean peekSet() throws TException { throw new TException("Peeking into a set not supported, likely because it's sized"); }
53545556575859
public void onewaySend(byte[] data) { } public void onewayThrow(int code) throws TException { throw new TException(); }
57585960616263
public void onewayThrow(int code) throws TException { throw new TException(); } public void throwUnexpected(int code) throws TException { throw new TException(); }
4748495051525354555657
selectThread.start(); } public void call(TAsyncMethodCall method) throws TException { if (!isRunning()) { throw new TException("SelectThread is not running"); } method.prepareMethodCall(); pendingCalls.add(method); selectThread.getSelector().wakeup(); }