def bind_end(self, stream, future):
if not isinstance(stream, Stream):<EOL><INDENT>future.set_result(None)<EOL><DEDENT>else:<EOL><INDENT>stream.pipe(TaskEndTransformer(future))<EOL><DEDENT>
Bind a 'TaskEndTransformer' to a stream.