언어

DataflowBlock 클래스

정의

데이터 흐름 블록을 사용하기 위한 정적(Visual Basic 공유) 메서드 집합을 제공합니다.

public ref class DataflowBlock abstract sealed
public static class DataflowBlock
type DataflowBlock = class
Public Module DataflowBlock
상속
DataflowBlock

메서드

속성 Description
AsObservable<TOutput>(ISourceBlock<TOutput>)

에 대한 새 IObservable<T> 추상화 만들기 ISourceBlock<TOutput>

AsObserver<TInput>(ITargetBlock<TInput>)

에 대한 새 IObserver<T> 추상화 만들기 ITargetBlock<TInput>

Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>, DataflowBlockOptions)

세 개의 데이터 흐름 원본을 모니터링하여 데이터를 먼저 사용할 수 있도록 하는 원본에 대해 제공된 처리기를 호출합니다.

Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>)

세 개의 데이터 흐름 원본을 모니터링하여 데이터를 먼저 사용할 수 있도록 하는 원본에 대해 제공된 처리기를 호출합니다.

Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, DataflowBlockOptions)

두 데이터 흐름 원본을 모니터링하여 데이터를 먼저 사용할 수 있도록 하는 원본에 대해 제공된 처리기를 호출합니다.

Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>)

두 데이터 흐름 원본을 모니터링하여 데이터를 먼저 사용할 수 있도록 하는 원본에 대해 제공된 처리기를 호출합니다.

Encapsulate<TInput,TOutput>(ITargetBlock<TInput>, ISourceBlock<TOutput>)

대상 및 원본을 단일 전파자로 캡슐화합니다.

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>.

NullTarget<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>.

적용 대상