Interface StreamProducer<T>

Type Parameters:

T - item type

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface StreamProducer<T>

Producer for a scheduler-managed result stream.

Method Summary

Modifier and Type	Method	Description
void	produce(WorkloadContext context, TaskCancellationToken cancellationToken, StreamEmitter<T> emitter)	Produces stream items through the emitter.

Method Details

produce

void produce(WorkloadContext context,
 TaskCancellationToken cancellationToken,
 StreamEmitter<T> emitter)
      throws Exception

Produces stream items through the emitter.

Parameters:

context - workload context

cancellationToken - cancellation token

emitter - item emitter

Throws:

Exception - producer failure