IReceivableSourceBlock<TOutput> Интерфейс

Ссылка

Определение

Пространство имен:: System.Threading.Tasks.Dataflow

Сборка:: System.Threading.Tasks.Dataflow.dll

Пакет:: System.Threading.Tasks.Dataflow v8.0.1

Пакет:: System.Threading.Tasks.Dataflow v9.0.0-rc.1.24431.7

Важно!

Некоторые сведения относятся к предварительной версии продукта, в которую до выпуска могут быть внесены существенные изменения. Майкрософт не предоставляет никаких гарантий, явных или подразумеваемых, относительно приведенных здесь сведений.

Представляет блок потока данных, который поддерживает получение сообщений без привязывания.

generic <typename TOutput>
public interface class IReceivableSourceBlock : System::Threading::Tasks::Dataflow::ISourceBlock<TOutput>

public interface IReceivableSourceBlock<TOutput> : System.Threading.Tasks.Dataflow.ISourceBlock<TOutput>

type IReceivableSourceBlock<'Output> = interface
    interface ISourceBlock<'Output>
    interface IDataflowBlock

type IReceivableSourceBlock<'Output> = interface
    interface IDataflowBlock
    interface ISourceBlock<'Output>

Public Interface IReceivableSourceBlock(Of TOutput)
Implements ISourceBlock(Of TOutput)

Параметры типа

TOutput

Указывает тип данных, поставляемых IReceivableSourceBlock<TOutput>.

Производный: System.Threading.Tasks.Dataflow.BatchBlock<T>

System.Threading.Tasks.Dataflow.BatchedJoinBlock<T1,T2>

System.Threading.Tasks.Dataflow.BatchedJoinBlock<T1,T2,T3>

System.Threading.Tasks.Dataflow.BroadcastBlock<T>

System.Threading.Tasks.Dataflow.BufferBlock<T>

Подробнее…

Реализации: IDataflowBlock ISourceBlock<TOutput>

Библиотека потоков данных TPL (пространство имен System.Threading.Tasks.Dataflow) не поставляется с .NET. Чтобы установить пространство имен System.Threading.Tasks.Dataflow в Visual Studio, откройте проект, выберите Управление пакетами NuGet в меню Проект и выполните поиск пакета System.Threading.Tasks.Dataflow в Интернете. Вы также можете установить его, выполнив в .NET Core CLI команду dotnet add package System.Threading.Tasks.Dataflow.

Свойства

Completion

Получает объект Task, представляющий асинхронную операцию и завершение блока потока данных.

(Унаследовано от IDataflowBlock)

Методы

Complete()	Сообщает блоку IDataflowBlock, что он больше не должен принимать и создавать никакие сообщения и не должен использовать отложенные сообщения. (Унаследовано от IDataflowBlock)
ConsumeMessage(DataflowMessageHeader, ITargetBlock<TOutput>, Boolean)	Вызывается связанным объектом ITargetBlock<TInput> для принятия и использования объекта DataflowMessageHeader, ранее предложенного этим объектом ISourceBlock<TOutput>. (Унаследовано от ISourceBlock<TOutput>)
Fault(Exception)	Вызывает выполнение IDataflowBlock в состоянии Faulted. (Унаследовано от IDataflowBlock)
LinkTo(ITargetBlock<TOutput>, DataflowLinkOptions)	Связывает объект ISourceBlock<TOutput> с указанным ITargetBlock<TInput>объектом . (Унаследовано от ISourceBlock<TOutput>)
ReleaseReservation(DataflowMessageHeader, ITargetBlock<TOutput>)	Вызывается связанным объектом ITargetBlock<TInput> для освобождения объекта DataflowMessageHeader, ранее зарезервированного этим объектом ISourceBlock<TOutput>. (Унаследовано от ISourceBlock<TOutput>)
ReserveMessage(DataflowMessageHeader, ITargetBlock<TOutput>)	Вызывается связанным объектом ITargetBlock<TInput> для резервирования объекта DataflowMessageHeader, ранее предложенного этим объектом ISourceBlock<TOutput>. (Унаследовано от ISourceBlock<TOutput>)
TryReceive(Predicate<TOutput>, TOutput)	Пытается синхронно получить доступный выходной элемент от интерфейса IReceivableSourceBlock<TOutput>.
TryReceiveAll(IList<TOutput>)	Пытается синхронно получить все доступные элементы от интерфейса IReceivableSourceBlock<TOutput>.

Методы расширения

AsObservable<TOutput>(ISourceBlock<TOutput>)	Создает новую абстракцию IObservable<T> для ISourceBlock<TOutput>.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)	Связывает объект ISourceBlock<TOutput> с указанным ITargetBlock<TInput>объектом .
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>)	Связывает с ISourceBlock<TOutput> указанным ITargetBlock<TInput> с помощью указанного фильтра.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>)	Связывает с ISourceBlock<TOutput> указанным ITargetBlock<TInput> с помощью указанного фильтра.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)	Предоставляет Task<TResult>, которое асинхронным образом выполняет мониторинг источника доступного вывода.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Предоставляет Task<TResult>, которое асинхронным образом выполняет мониторинг источника доступного вывода.
Receive<TOutput>(ISourceBlock<TOutput>)	Синхронно получает значение от указанного источника.
Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Синхронно получает значение из указанного источника и предоставляет токен для отмены операции.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan)	Синхронно получает значение из указанного источника, отслеживание необязательно точкой времени ожидания.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	Синхронно получает значение из указанного источника, обеспечивая токен для отмены операции за необязательным и интервал времени ожидания.
ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken)	Создает объект , IAsyncEnumerable<T> который позволяет получать все данные из источника.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>)	Асинхронно получает значение от указанного источника.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Асинхронно получает значение из указанного источника и предоставляет токен для отмены операции.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan)	Асинхронно получает значение из указанного источника, отслеживание необязательно точкой времени ожидания.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	Асинхронно получает значение из указанного источника, обеспечивая токен для отмены операции за необязательным и интервал времени ожидания.
TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput)	Пытается синхронно получить элемент из ISourceBlock<TOutput>.

Применяется к

Поделиться через