Bind a 'TaskEndTransformer' to a stream.

def bind_end(self, stream, future):
		"""Bind a 'TaskEndTransformer' to a stream."""
		if not isinstance(stream, Stream):
			future.set_result(None)
		else:
			stream.pipe(TaskEndTransformer(future))