Package com.embabel.agent.a2a.server.support

Class A2AStreamingHandler

  • All Implemented Interfaces:
    @Service()@Profile(value = {"a2a"}) 
public final class A2AStreamingHandler

    Handles streaming functionality for A2A messages

    • Nested Class Summary

      Nested Classes 
      Modifier and Type Class Description

    • Field Summary

      Fields 
      Modifier and Type Field Description

    • Constructor Summary

      Constructors 
      Constructor Description
      A2AStreamingHandler(ObjectMapper objectMapper)

    • Enum Constant Summary

      Enum Constants 
      Enum Constant Description

    • Method Summary

      Modifier and Type Method Description
      final SseEmitter createStream(String streamId) Creates a new SSE stream for the given stream ID
      final Unit sendStreamEvent(String streamId, StreamingEventKind event) Sends a streaming event to the specified stream
      final Unit closeStream(String streamId) Closes the specified stream
      final Unit shutdown() Shuts down the streaming handler

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • A2AStreamingHandler

        A2AStreamingHandler(ObjectMapper objectMapper)

    • Method Detail

      • createStream

         final SseEmitter createStream(String streamId)

        Creates a new SSE stream for the given stream ID

      • sendStreamEvent

         final Unit sendStreamEvent(String streamId, StreamingEventKind event)

        Sends a streaming event to the specified stream

      • shutdown

         final Unit shutdown()

        Shuts down the streaming handler