90publishingActivity = await activityReporter.ActivityItemUpdated.Reader.ReadAsync(linkedToken).ConfigureAwait(false);

78await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 115await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 139await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 172await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 205ActivityItemUpdated.Writer.TryWrite(state); 246await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 277await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 369await ActivityItemUpdated.Writer.WriteAsync(activity, cancellationToken).ConfigureAwait(false); 400await ActivityItemUpdated.Writer.WriteAsync(activity, cancellationToken).ConfigureAwait(false);

43var activityReader = reporter.ActivityItemUpdated.Reader; 68var activityReader = reporter.ActivityItemUpdated.Reader; 88reporter.ActivityItemUpdated.Reader.TryRead(out _); 96var activityReader = reporter.ActivityItemUpdated.Reader; 114reporter.ActivityItemUpdated.Reader.TryRead(out _); 130var activityReader = reporter.ActivityItemUpdated.Reader; 184reporter.ActivityItemUpdated.Reader.TryRead(out _); 195var activityReader = reporter.ActivityItemUpdated.Reader; 216reporter.ActivityItemUpdated.Reader.TryRead(out _); 217reporter.ActivityItemUpdated.Reader.TryRead(out _); 228var activityReader = reporter.ActivityItemUpdated.Reader; 288reporter.ActivityItemUpdated.Reader.TryRead(out _); 289reporter.ActivityItemUpdated.Reader.TryRead(out _); 301var activityReader = reporter.ActivityItemUpdated.Reader; 344var activityReader = reporter.ActivityItemUpdated.Reader; 365var activityReader = reporter.ActivityItemUpdated.Reader; 398var activityReader = reporter.ActivityItemUpdated.Reader; 568var activityReader = reporter.ActivityItemUpdated.Reader; 599var activityReader = reporter.ActivityItemUpdated.Reader; 628var activityReader = reporter.ActivityItemUpdated.Reader; 658var activity = await reporter.ActivityItemUpdated.Reader.ReadAsync().DefaultTimeout(); 698var activity = await reporter.ActivityItemUpdated.Reader.ReadAsync().DefaultTimeout(); 727var activityReader = reporter.ActivityItemUpdated.Reader; 774reporter.ActivityItemUpdated.Reader.TryRead(out _); 784var activityReader = reporter.ActivityItemUpdated.Reader; 818var activityReader = reporter.ActivityItemUpdated.Reader; 862reporter.ActivityItemUpdated.Reader.TryRead(out _); 863reporter.ActivityItemUpdated.Reader.TryRead(out _); 875var activityReader = reporter.ActivityItemUpdated.Reader; 897reporter.ActivityItemUpdated.Reader.TryRead(out _); 898reporter.ActivityItemUpdated.Reader.TryRead(out _); 910var activityReader = reporter.ActivityItemUpdated.Reader; 934var activityReader = reporter.ActivityItemUpdated.Reader; 955var activityReader = reporter.ActivityItemUpdated.Reader; 981var activityReader = reporter.ActivityItemUpdated.Reader; 1008var activityReader = reporter.ActivityItemUpdated.Reader; 1031var activityReader = reporter.ActivityItemUpdated.Reader; 1045reporter.ActivityItemUpdated.Reader.TryRead(out _); // Clear step activity 1056var activityReader = reporter.ActivityItemUpdated.Reader; 1074reporter.ActivityItemUpdated.Reader.TryRead(out _); 1081var activityReader = reporter.ActivityItemUpdated.Reader; 1125reporter.ActivityItemUpdated.Reader.TryRead(out _); 1126reporter.ActivityItemUpdated.Reader.TryRead(out _); 1136var activityReader = reporter.ActivityItemUpdated.Reader; 1148reporter.ActivityItemUpdated.Reader.TryRead(out _); // Clear step activity 1155var activityReader = reporter.ActivityItemUpdated.Reader; 1175var activityReader = reporter.ActivityItemUpdated.Reader; 1195var activityReader = reporter.ActivityItemUpdated.Reader; 1214var activityReader = reporter.ActivityItemUpdated.Reader; 1382while (reporter.ActivityItemUpdated.Reader.TryRead(out _)) { } 1387Assert.False(reporter.ActivityItemUpdated.Reader.TryRead(out _));