statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/reqreply/RequestReplyFunction.java
/** Sends a {@link InvocationBatchRequest} to the remote function. */
Sends a  InvocationBatchRequest to the remote function.
Sends a InvocationBatchRequest to the remote function .
private void sendToFunction(Context context, InvocationBatchRequest.Builder batchBuilder) {
    batchBuilder.setTarget(sdkAddressToPolyglotAddress(context.self()));
    managedStates.attachStateValues(batchBuilder);
    ToFunction toFunction = ToFunction.newBuilder().setInvocation(batchBuilder).build();
    sendToFunction(context, toFunction);
  }
private void sendToFunction ( Context context , InvocationBatchRequest . Builder batchBuilder ) { batchBuilder . setTarget ( sdkAddressToPolyglotAddress ( context . self ( ) ) ) ; managedStates . attachStateValues ( batchBuilder ) ; ToFunction toFunction = ToFunction . newBuilder ( ) . setInvocation ( batchBuilder ) . build ( ) ; sendToFunction ( context , toFunction ) ; }
Sends a {@link InvocationBatchRequest} to the remote function.
Sends a { @link InvocationBatchRequest } to the remote function .