Tell the consumer that no futher streams will be added.
Returns a future that is completed when the consumer is done handling events.
Source
/**
* Tell the consumer that no futher streams will be added.
*
* Returns a future that is completed when the consumer is done handling
* events.
*/
Future close();