Package com.rpl.agentorama

Interface AgentClient.StreamAllCallback<T>

Type Parameters:
T - the type of data being streamed
Enclosing interface:
AgentClient
public static interface AgentClient.StreamAllCallback<T>
Callback interface for streaming data from all invocations of a specific node.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    onUpdate(Map<UUID,List<T>> allChunks, Map<UUID,List<T>> newChunks, Set<UUID> resetInvokeIds, boolean isComplete)
    Called when new data chunks are available from any node invocation.

  • Method Details

    • onUpdate

      void onUpdate(Map<UUID,List<T>> allChunks, Map<UUID,List<T>> newChunks, Set<UUID> resetInvokeIds, boolean isComplete)
      Called when new data chunks are available from any node invocation.
      Parameters:
      allChunks - all chunks received so far, grouped by invoke ID
      newChunks - new chunks in this update, grouped by invoke ID
      resetInvokeIds - set of invoke IDs that were reset because nodes failed and retried
      isComplete - true if streaming is finished across all node invocations for the agent invoke