summaryrefslogtreecommitdiff
path: root/java/src/Ice/ConnectionI.java
diff options
context:
space:
mode:
authorJose <jose@zeroc.com>2014-04-18 21:44:03 +0200
committerJose <jose@zeroc.com>2014-04-18 21:44:03 +0200
commit8324b6221eaf415dd482453a4bbca872e5a8e1af (patch)
treeb9a7a8783c81d0fcac2c2545bfdb42d8dc53b569 /java/src/Ice/ConnectionI.java
parentFixed (ICE-4858) - Eliminate IceDB (diff)
downloadice-8324b6221eaf415dd482453a4bbca872e5a8e1af.tar.bz2
ice-8324b6221eaf415dd482453a4bbca872e5a8e1af.tar.xz
ice-8324b6221eaf415dd482453a4bbca872e5a8e1af.zip
Fixed (ICE-5507) - Support Java 8 lambda expression
Diffstat (limited to 'java/src/Ice/ConnectionI.java')
-rw-r--r--java/src/Ice/ConnectionI.java22
1 files changed, 22 insertions, 0 deletions
diff --git a/java/src/Ice/ConnectionI.java b/java/src/Ice/ConnectionI.java
index 5392a5db616..7785c2d2226 100644
--- a/java/src/Ice/ConnectionI.java
+++ b/java/src/Ice/ConnectionI.java
@@ -671,6 +671,28 @@ public final class ConnectionI extends IceInternal.EventHandler implements Conne
{
return begin_flushBatchRequestsInternal(cb);
}
+
+ public AsyncResult
+ begin_flushBatchRequests(IceInternal.Functional_VoidCallback __responseCb,
+ IceInternal.Functional_GenericCallback1<Ice.LocalException> __localExceptionCb,
+ IceInternal.Functional_BoolCallback __sentCb)
+ {
+ return begin_flushBatchRequestsInternal(
+ new IceInternal.Functional_CallbackBase(false, __localExceptionCb, __sentCb)
+ {
+ public final void __completed(AsyncResult __result)
+ {
+ try
+ {
+ __result.getConnection().end_flushBatchRequests(__result);
+ }
+ catch(LocalException __ex)
+ {
+ __localExceptionCb.apply(__ex);
+ }
+ }
+ });
+ }
private Ice.AsyncResult
begin_flushBatchRequestsInternal(IceInternal.CallbackBase cb)