eventpipe

type Local struct {
	Reader Reader
	Writer Writer
	// contains filtered or unexported fields
}

type LocalPipeOption func(*localOptions)

type Reader interface {
	// Read dequeues an event or blocks if the queue is empty.
	Read(ctx context.Context) (a2a.Event, error)
}

type Writer interface {
	// Write enqueues an event or blocks if the queue is full.
	Write(ctx context.Context, event a2a.Event) error
}