WriteOnceBlock<T> Класс
Определение
Важно!
Некоторые сведения относятся к предварительной версии продукта, в которую до выпуска могут быть внесены существенные изменения. Майкрософт не предоставляет никаких гарантий, явных или подразумеваемых, относительно приведенных здесь сведений.
Предоставляет буфер для получения и хранения не более одного элемента в сети блоков потока данных.
generic <typename T>
public ref class WriteOnceBlock sealed : System::Threading::Tasks::Dataflow::IPropagatorBlock<T, T>, System::Threading::Tasks::Dataflow::IReceivableSourceBlock<T>, System::Threading::Tasks::Dataflow::ISourceBlock<T>, System::Threading::Tasks::Dataflow::ITargetBlock<T>public sealed class WriteOnceBlock<T> : System.Threading.Tasks.Dataflow.IPropagatorBlock<T,T>, System.Threading.Tasks.Dataflow.IReceivableSourceBlock<T>, System.Threading.Tasks.Dataflow.ISourceBlock<T>, System.Threading.Tasks.Dataflow.ITargetBlock<T>type WriteOnceBlock<'T> = class
interface IPropagatorBlock<'T, 'T>
interface ITargetBlock<'T>
interface IDataflowBlock
interface ISourceBlock<'T>
interface IReceivableSourceBlock<'T>type WriteOnceBlock<'T> = class
interface IDataflowBlock
interface IPropagatorBlock<'T, 'T>
interface ISourceBlock<'T>
interface ITargetBlock<'T>
interface IReceivableSourceBlock<'T>Public NotInheritable Class WriteOnceBlock(Of T)
Implements IPropagatorBlock(Of T, T), IReceivableSourceBlock(Of T), ISourceBlock(Of T), ITargetBlock(Of T)Параметры типа
- T
Указывает тип данных, буфериченных этим блоком потока данных.
- Наследование
-
WriteOnceBlock<T>
- Реализации
Комментарии
Note
Библиотека потоков данных TPL (пространство имен System.Threading.Tasks.Dataflow) не распространяется с помощью .NET. Чтобы установить пространство имен System.Threading.Tasks.Dataflow в Visual Studio, откройте проект, выберите Управление пакетами NuGet в меню Project и найдите пакет System.Threading.Tasks.Dataflow в Интернете. Кроме того, чтобы установить его с помощью cli .NET Core, запустите dotnet add package System.Threading.Tasks.Dataflow.
Конструкторы
| Имя | Описание |
|---|---|
| WriteOnceBlock<T>(Func<T,T>, DataflowBlockOptions) |
Инициализирует новый WriteOnceBlock<T> с указанным DataflowBlockOptions. |
| WriteOnceBlock<T>(Func<T,T>) |
Инициализирует новый WriteOnceBlock<T>. |
Свойства
| Имя | Описание |
|---|---|
| Completion |
Возвращает объект Task , представляющий асинхронную операцию и завершение блока потока данных. |
Методы
| Имя | Описание |
|---|---|
| Complete() |
Сигналит о IDataflowBlock том, что он не должен принимать и не создавать больше сообщений, а также не потреблять больше отложенных сообщений. |
| Equals(Object) |
Определяет, равен ли указанный объект текущему объекту. (Унаследовано от Object) |
| GetHashCode() |
Служит хэш-функцией по умолчанию. (Унаследовано от Object) |
| GetType() |
Возвращает Type текущего экземпляра. (Унаследовано от Object) |
| LinkTo(ITargetBlock<T>, DataflowLinkOptions) |
Связывает указанный ISourceBlock<TOutput>ITargetBlock<TInput> объект. |
| MemberwiseClone() |
Создает неглубокую копию текущей Object. (Унаследовано от Object) |
| ToString() |
Возвращает строку, представляющую отформатированное имя этого IDataflowBlock экземпляра. |
| TryReceive(Predicate<T>, T) |
Пытается синхронно получать доступный выходной элемент из .IReceivableSourceBlock<TOutput> |
Явные реализации интерфейса
Методы расширения
| Имя | Описание |
|---|---|
| AsObservable<TOutput>(ISourceBlock<TOutput>) |
Создает новую IObservable<T> абстракцию поверх ISourceBlock<TOutput>. |
| AsObserver<TInput>(ITargetBlock<TInput>) |
Создает новую IObserver<T> абстракцию поверх ITargetBlock<TInput>. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>) |
ISourceBlock<TOutput> Связывает указанный ITargetBlock<TInput> с помощью указанного фильтра. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>) |
ISourceBlock<TOutput> Связывает указанный ITargetBlock<TInput> с помощью указанного фильтра. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>) |
Связывает указанный ISourceBlock<TOutput>ITargetBlock<TInput>объект. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Предоставляет асинхронный Task<TResult> мониторинг источника для доступных выходных данных. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>) |
Предоставляет асинхронный Task<TResult> мониторинг источника для доступных выходных данных. |
| Post<TInput>(ITargetBlock<TInput>, TInput) |
Отправляет элемент в элемент ITargetBlock<TInput>. |
| Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Синхронно получает значение из указанного источника и предоставляет маркер для отмены операции. |
| Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) |
Синхронно получает значение из указанного источника, предоставляя маркер для отмены операции и наблюдая за необязательным интервалом времени ожидания. |
| Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Синхронно получает значение из указанного источника, наблюдая за необязательным периодом ожидания. |
| Receive<TOutput>(ISourceBlock<TOutput>) |
Синхронно получает значение из указанного источника. |
| ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken) |
Создает объект IAsyncEnumerable<T> , позволяющий получать все данные из источника. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Асинхронно получает значение из указанного источника и предоставляет маркер для отмены операции. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) |
Асинхронно получает значение из указанного источника, предоставляя маркер для отмены операции и наблюдая необязательный интервал времени ожидания. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Асинхронно получает значение из указанного источника, наблюдая за необязательным периодом ожидания. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>) |
Асинхронно получает значение из указанного источника. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken) |
Асинхронно предлагает сообщение целевому блоку сообщений, что позволяет отложить. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput) |
Асинхронно предлагает сообщение целевому блоку сообщений, что позволяет отложить. |
| TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput) |
Пытается синхронно получить элемент из элемента ISourceBlock<TOutput>. |
