Package xyz.felh.openai

Class StreamListener<T extends IOpenAiApiObject>

java.lang.Object
xyz.felh.openai.StreamListener<T>
public abstract class StreamListener<T extends IOpenAiApiObject> extends Object

  • Constructor Summary

    Constructors
    Constructor
    Description
    StreamListener()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    close()
    cancel eventSource
    void
    onClosed(String requestId)
    No further calls to this listener will be made.
    void
    onEvent(String requestId, T t)
    event line
    void
    onEventDone(String requestId)
    event message finished, get payload [DONE]
    void
    onFailure(String requestId, Throwable t, okhttp3.Response response)
    Invoked when an event source has been closed due to an error reading from or writing to the network.
    void
    onOpen(String requestId, okhttp3.Response response)
    Invoked when an event source has been accepted by the remote peer and may begin transmitting events.

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • StreamListener

      public StreamListener()

  • Method Details

    • onOpen

      public void onOpen(String requestId, okhttp3.Response response)
      Invoked when an event source has been accepted by the remote peer and may begin transmitting events.
      Parameters:
      requestId - request ID
      response - OK http response

    • onEvent

      public void onEvent(String requestId, T t)
      event line
      Parameters:
      requestId - request ID
      t - return IOpenAiApiObject

    • onEventDone

      public void onEventDone(String requestId)
      event message finished, get payload [DONE]
      Parameters:
      requestId - request ID

    • onClosed

      public void onClosed(String requestId)

      No further calls to this listener will be made.

      Parameters:
      requestId - request ID

    • onFailure

      public void onFailure(String requestId, Throwable t, okhttp3.Response response)
      Invoked when an event source has been closed due to an error reading from or writing to the network. Incoming events may have been lost. No further calls to this listener will be made.
      Parameters:
      requestId - request ID
      t - throwable
      response - response

    • close

      public void close()
      cancel eventSource