7 references to CorrelationPayloads
Microsoft.DotNet.Helix.JobSender (7)
JobDefinition.cs (7)
64CorrelationPayloads.Add(new UriPayload(uri), "");
73CorrelationPayloads.Add(new UriPayload(uri), destination);
95CorrelationPayloads.Add(new DirectoryPayload(directory, archiveEntryPrefix), destination);
101CorrelationPayloads.Add(new AdhocPayload(files), "");
107CorrelationPayloads.Add(new AdhocPayload(files.ToArray()), destination);
113CorrelationPayloads.Add(new ArchivePayload(archive), destination);
181(await Task.WhenAll(CorrelationPayloads.Select(async p => (uri: await p.Key.UploadAsync(storageContainer, log, cancellationToken), destination: p.Value)))).ToDictionary(x => x.uri, x => x.destination);