Package com.rpl.agentorama

Interface AgentClient.StreamCallback<T>

Type Parameters:
T - the type of chunks being streamed
Enclosing interface:
AgentClient
public static interface AgentClient.StreamCallback<T>
Callback interface for streaming data from a single node invoke.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    onUpdate(List<T> allChunks, List<T> newChunks, boolean isReset, boolean isComplete)
    Called when new data chunks are available.

  • Method Details

    • onUpdate

      void onUpdate(List<T> allChunks, List<T> newChunks, boolean isReset, boolean isComplete)
      Called when new data chunks are available.
      Parameters:
      allChunks - all chunks received so far
      newChunks - new chunks in this update
      isReset - true if the stream was reset because the node failed and retried
      isComplete - true if streaming is finished