in processing-pipelines/common/csharp/CloudEventWriter.cs [40:54]
public async Task Write(object eventData, HttpContext context)
{
var replyEvent = new CloudEvent
{
Type = _eventType,
Source = new Uri($"urn:{_eventSource}"),
Time = DateTimeOffset.Now,
DataContentType = "application/json",
Id = Guid.NewGuid().ToString(),
Data = eventData
};
_logger.LogInformation("Replying with CloudEvent\n" + replyEvent.GetLog());
await replyEvent.CopyToHttpResponseAsync(context.Response, ContentMode.Binary, formatter);
}