IReceivableSourceBlock<TOutput> 인터페이스

정의

연결하지 않고 메시지 수신을 지원하는 데이터 흐름 블록을 나타냅니다.

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>지정합니다.

파생
구현

설명

메모

TPL 데이터 흐름 라이브러리(System.Threading.Tasks.Dataflow 네임스페이스)는 .NET과 함께 배포되지 않습니다. Visual Studio에서 System.Threading.Tasks.Dataflow 네임스페이스를 설치하려면, 프로젝트를 열고 프로젝트 메뉴에서 NuGet 패키지 관리를 선택한 다음, System.Threading.Tasks.Dataflow 패키지를 온라인으로 검색합니다. 대안으로, .NET Core CLI 을 사용하여을 설치하려면, dotnet add package System.Threading.Tasks.Dataflow을 실행하십시오.

속성

Name Description
Completion

Task 데이터 흐름 블록의 비동기 작업 및 완료를 나타내는 값을 가져옵니다.

(다음에서 상속됨 IDataflowBlock)

메서드

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

확장명 메서드

Name Description
AsObservable<TOutput>(ISourceBlock<TOutput>)

에 대한 새 IObservable<T> 추상화 만들기 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>.

OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)

소스에서 Task<TResult> 사용 가능한 출력을 비동기적으로 모니터링하는 기능을 제공합니다.

OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)

소스에서 Task<TResult> 사용 가능한 출력을 비동기적으로 모니터링하는 기능을 제공합니다.

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

지정된 원본에서 값을 비동기적으로 받습니다.

TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput)

에서 항목을 동기적으로 수신하려고 시도합니다 ISourceBlock<TOutput>.

적용 대상