StreamProducer (com.gengoai:mango 1.1-SNAPSHOT API)

java.lang.Object
- com.gengoai.concurrent.Broker.Producer<V>
- - com.gengoai.concurrent.StreamProducer<V>

Type Parameters:

V - the type of item being produced.
```
public class StreamProducer<V>
extends Broker.Producer<V>
```
A producer implementation that produces items from a stream

Author:

David B. Bracewell

- Constructor Summary
  
  Constructors
  Constructor Description
  
  StreamProducer(Stream<? extends V> stream)
  Instantiates a new Stream producer.
- Method Summary
  
  All Methods Instance Methods Concrete Methods
  Modifier and Type Method Description
  
  void produce()
  Logic for producing items to be consumed.
  - Methods inherited from class com.gengoai.concurrent.Broker.Producer
    isRunning, start, stop, yield
  - Methods inherited from class java.lang.Object
    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - StreamProducer
```
public StreamProducer(Stream<? extends V> stream)
```
    Instantiates a new Stream producer.
    
    Parameters:
    
    stream - the stream
- Method Detail
  - produce
```
public void produce()
```
    Description copied from class: Broker.Producer
    
    Logic for producing items to be consumed.
    
    Specified by:
    
    produce in class Broker.Producer<V>