Home
last modified time | relevance | path

Searched refs:resultHandler (Results 1 – 4 of 4) sorted by relevance

/thrift-3.4.0/lib/java/src/test/java/org/apache/thrift/test/voidmethexceptions/
DServiceAsyncImp.java32 String msg, boolean throwException, AsyncMethodCallback<String> resultHandler) in returnString() argument
35 resultHandler.onError(new TExampleException(msg)); in returnString()
37 resultHandler.onComplete(msg); in returnString()
43 String msg, boolean throwException, AsyncMethodCallback<Void> resultHandler) in returnVoidThrows() argument
46 resultHandler.onError(new TExampleException(msg)); in returnVoidThrows()
48 resultHandler.onComplete(null); in returnVoidThrows()
54 String msg, boolean throwException, AsyncMethodCallback<Void> resultHandler) in returnVoidNoThrowsRuntimeException() argument
57 resultHandler.onError(new RuntimeException(msg)); in returnVoidNoThrowsRuntimeException()
59 resultHandler.onComplete(null); in returnVoidNoThrowsRuntimeException()
65 String msg, boolean throwException, AsyncMethodCallback<Void> resultHandler) in returnVoidNoThrowsTApplicationException() argument
[all …]
/thrift-3.4.0/lib/java/src/test/java/org/apache/thrift/server/
DServerTestBase.java649 public void testVoid(AsyncMethodCallback<Void> resultHandler) throws TException {
650 resultHandler.onComplete(null);
654 public void testString(String thing, AsyncMethodCallback<String> resultHandler)
656 resultHandler.onComplete(handler.testString(thing));
660 public void testBool(boolean thing, AsyncMethodCallback<Boolean> resultHandler)
662 resultHandler.onComplete(handler.testBool(thing));
666 public void testByte(byte thing, AsyncMethodCallback<Byte> resultHandler) throws TException {
667 resultHandler.onComplete(handler.testByte(thing));
671 public void testI32(int thing, AsyncMethodCallback<Integer> resultHandler) throws TException {
672 resultHandler.onComplete(handler.testI32(thing));
[all …]
/thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/
DTBaseAsyncProcessor.java101 AsyncMethodCallback resultHandler = fn.getResultHandler(fb, msg.seqid); in process() local
103 fn.start(iface, args, resultHandler); in process()
106 resultHandler.onError(e); in process()
DAsyncProcessFunction.java35 public abstract void start(I iface, T args, AsyncMethodCallback<R> resultHandler) in start() argument