언어

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

파생
구현

속성

속성 Description
Completion

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

(다음에서 상속됨 IDataflowBlock)

메서드

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

확장명 메서드

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

적용 대상