This should be similar to what merge operator does with async document processing. We want to use the same logic for the new webhook emit sink, so going to place the common code into a separate class