SourceQueueWithComplete

All Superinterfaces:

SourceQueue<T>
```
public interface SourceQueueWithComplete<T>
extends SourceQueue<T>
```
Complete the stream normally. Use watchCompletion to be notified of this operation’s success.
Note that this only means the elements have been passed downstream, not that downstream has successfully processed them.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`void`	`complete()`	Complete the stream normally.
`void`	`fail(java.lang.Throwable ex)`	Complete the stream with a failure.
`scala.concurrent.Future<Done>`	`watchCompletion()`	Method returns a `Future` that will be completed if this operator completes, or will be failed when the stream fails, for example when `SourceQueueWithComplete.fail` is invoked.

Methods inherited from interface akka.stream.scaladsl.SourceQueue
offer

- Method Detail
  - complete
```
void complete()
```
    Complete the stream normally. Use watchCompletion to be notified of this operation’s success.
    Note that this only means the elements have been passed downstream, not that downstream has successfully processed them.
  - fail
```
void fail(java.lang.Throwable ex)
```
    Complete the stream with a failure. Use watchCompletion to be notified of this operation’s success.
    
    Parameters:
    
    ex - (undocumented)
  - watchCompletion
```
scala.concurrent.Future<Done> watchCompletion()
```
    Method returns a Future that will be completed if this operator completes, or will be failed when the stream fails, for example when SourceQueueWithComplete.fail is invoked.
    Note that this only means the elements have been passed downstream, not that downstream has successfully processed them.
    
    Specified by:
    
    watchCompletion in interface SourceQueue<T>
    
    Returns:
    
    (undocumented)