Package com.avoka.fc.core.stream

Interface StreamCallback<V>

public interface StreamCallback<V>
Provides a callback interface that the user can implement to allow code to execute when the request is complete. Type will be specified in producers which expects call back.
Since:
22.10.0

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    onCompletion(V metadata, Exception exception)
    A callback method which the user can implement to provide asynchronous handling of request completion.

  • Method Details

    • onCompletion

      void onCompletion(V metadata, Exception exception)
      A callback method which the user can implement to provide asynchronous handling of request completion. This method will be called when the record sent to the server has been acknowledged.
      Parameters:
      metadata - the metadata for the record that was sent
      exception - The exception thrown during processing of this record.