ai-mocks-a2a/dev.mokksy.aimocks.a2a/SendStreamingMessageResponseSpecification

SendStreamingMessageResponseSpecification

class SendStreamingMessageResponseSpecification(var responseFlow: Flow<TaskUpdateEvent>? = null, var delayBetweenChunks: Duration = Duration.ZERO, var error: JSONRPCError? = null, delay: Duration = Duration.ZERO) : AbstractResponseSpecification<SendStreamingMessageRequest, String> (source)

Constructors

SendStreamingMessageResponseSpecification

constructor(responseFlow: Flow<TaskUpdateEvent>? = null, delayBetweenChunks: Duration = Duration.ZERO, error: JSONRPCError? = null, delay: Duration = Duration.ZERO)

Properties

var delay: Duration

delayBetweenChunks

var delayBetweenChunks: Duration

var error: JSONRPCError?

var responseFlow: Flow<TaskUpdateEvent>?

Functions

fun delay(delay: Duration): SendStreamingMessageResponseSpecification

delayBetweenChunks

fun delayBetweenChunks(delay: Duration): SendStreamingMessageResponseSpecification

open override fun delayMillis(value: Long)

fun SendStreamingMessageResponseSpecification.publisher(publisher: Flow.Publisher<TaskUpdateEvent>)

fun responseFlow(flow: Flow<TaskUpdateEvent>): SendStreamingMessageResponseSpecification

Java-friendly setter for responseFlow.

fun stream(stream: Stream<TaskUpdateEvent>): SendStreamingMessageResponseSpecification