1 write to _owningBatch
System.Threading.Tasks.Dataflow (1)
14 references to _owningBatch
System.Threading.Tasks.Dataflow (14)
Blocks\BatchBlock.cs (14)
381messageValue = source.ConsumeMessage(messageHeader, _owningBatch, out consumed)!;
437_owningBatch._source.AddException(exception);
449catch (Exception e) { _owningBatch._source.AddException(e); }
480return _dataflowBlockOptions.CancellationToken.IsCancellationRequested || _owningBatch._source.HasExceptions;
531Common.ReleaseAllPostponedMessages(targetCore._owningBatch,
540targetCore._owningBatch._source.AddExceptions(exceptions);
645_owningBatch, _nonGreedyState.TaskForInputProcessing, DataflowEtwProvider.TaskLaunchedReason.ProcessingInputMessages,
790if (sourceAndMessage.Key.ReserveMessage(sourceAndMessage.Value, _owningBatch))
808if (sourceAndMessage.Key.ReserveMessage(sourceAndMessage.Value, _owningBatch))
996T? consumedValue = sourceAndMessage.Key.ConsumeMessage(sourceAndMessage.Value.Key, _owningBatch, out consumed);
1048T? consumedValue = sourceAndMessage.Key.ConsumeMessage(sourceAndMessage.Value.Key, _owningBatch, out consumed);
1097try { source.ReleaseReservation(message.Key, _owningBatch); }
1161var displayBatch = _owningBatch as IDebuggerDisplay;
1162return $"Block = \"{(displayBatch != null ? displayBatch.Content : _owningBatch)}\"";