- public <T extends DataObject, F> Future<RpcResult<T>> handleServiceCall(final BigInteger connectionID,
- final Function<DataCrate<T>, Future<RpcResult<F>>> function) {
- LOG.debug("Calling the FlowMod RPC method on MessageDispatchService");
+ /**
+ * @param connectionID connection identifier
+ * @param function data sender
+ * @param <T> rpc result backend type
+ * @param <F> final rpc backend type
+ * @return
+ */
+ public <T, F> ListenableFuture<RpcResult<T>> handleServiceCall(final BigInteger connectionID,
+ final Function<DataCrate<T>, ListenableFuture<RpcResult<F>>> function) {
+ DataCrateBuilder<T> dataCrateBuilder = DataCrateBuilder.<T>builder();
+ return handleServiceCall(function, dataCrateBuilder);
+ }
+
+ public <T, F> ListenableFuture<RpcResult<T>> handleServiceCall(final Function<DataCrate<T>, ListenableFuture<RpcResult<F>>> function) {
+ DataCrateBuilder<T> dataCrateBuilder = DataCrateBuilder.<T>builder();
+ return handleServiceCall(function, dataCrateBuilder);
+ }