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

76await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 113await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 137await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 170await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 203ActivityItemUpdated.Writer.TryWrite(state); 244await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 275await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 367await ActivityItemUpdated.Writer.WriteAsync(activity, cancellationToken).ConfigureAwait(false); 398await ActivityItemUpdated.Writer.WriteAsync(activity, cancellationToken).ConfigureAwait(false);

41var activityReader = reporter.ActivityItemUpdated.Reader; 66var activityReader = reporter.ActivityItemUpdated.Reader; 86reporter.ActivityItemUpdated.Reader.TryRead(out _); 94var activityReader = reporter.ActivityItemUpdated.Reader; 112reporter.ActivityItemUpdated.Reader.TryRead(out _); 128var activityReader = reporter.ActivityItemUpdated.Reader; 182reporter.ActivityItemUpdated.Reader.TryRead(out _); 193var activityReader = reporter.ActivityItemUpdated.Reader; 214reporter.ActivityItemUpdated.Reader.TryRead(out _); 215reporter.ActivityItemUpdated.Reader.TryRead(out _); 226var activityReader = reporter.ActivityItemUpdated.Reader; 286reporter.ActivityItemUpdated.Reader.TryRead(out _); 287reporter.ActivityItemUpdated.Reader.TryRead(out _); 299var activityReader = reporter.ActivityItemUpdated.Reader; 342var activityReader = reporter.ActivityItemUpdated.Reader; 363var activityReader = reporter.ActivityItemUpdated.Reader; 396var activityReader = reporter.ActivityItemUpdated.Reader; 566var activityReader = reporter.ActivityItemUpdated.Reader; 597var activityReader = reporter.ActivityItemUpdated.Reader; 626var activityReader = reporter.ActivityItemUpdated.Reader; 656var activity = await reporter.ActivityItemUpdated.Reader.ReadAsync().DefaultTimeout(); 696var activity = await reporter.ActivityItemUpdated.Reader.ReadAsync().DefaultTimeout(); 725var activityReader = reporter.ActivityItemUpdated.Reader; 772reporter.ActivityItemUpdated.Reader.TryRead(out _); 782var activityReader = reporter.ActivityItemUpdated.Reader; 816var activityReader = reporter.ActivityItemUpdated.Reader; 860reporter.ActivityItemUpdated.Reader.TryRead(out _); 861reporter.ActivityItemUpdated.Reader.TryRead(out _); 873var activityReader = reporter.ActivityItemUpdated.Reader; 895reporter.ActivityItemUpdated.Reader.TryRead(out _); 896reporter.ActivityItemUpdated.Reader.TryRead(out _); 908var activityReader = reporter.ActivityItemUpdated.Reader; 932var activityReader = reporter.ActivityItemUpdated.Reader; 953var activityReader = reporter.ActivityItemUpdated.Reader; 979var activityReader = reporter.ActivityItemUpdated.Reader; 1006var activityReader = reporter.ActivityItemUpdated.Reader; 1029var activityReader = reporter.ActivityItemUpdated.Reader; 1043reporter.ActivityItemUpdated.Reader.TryRead(out _); // Clear step activity 1054var activityReader = reporter.ActivityItemUpdated.Reader; 1072reporter.ActivityItemUpdated.Reader.TryRead(out _); 1079var activityReader = reporter.ActivityItemUpdated.Reader; 1123reporter.ActivityItemUpdated.Reader.TryRead(out _); 1124reporter.ActivityItemUpdated.Reader.TryRead(out _); 1134var activityReader = reporter.ActivityItemUpdated.Reader; 1146reporter.ActivityItemUpdated.Reader.TryRead(out _); // Clear step activity 1153var activityReader = reporter.ActivityItemUpdated.Reader; 1173var activityReader = reporter.ActivityItemUpdated.Reader; 1193var activityReader = reporter.ActivityItemUpdated.Reader; 1212var activityReader = reporter.ActivityItemUpdated.Reader; 1380while (reporter.ActivityItemUpdated.Reader.TryRead(out _)) { } 1385Assert.False(reporter.ActivityItemUpdated.Reader.TryRead(out _));