docs: def pipe(inpipe, outpipe):
  		"""Connect inpipe and outpipe.  If outpipe is not a Stream instance,
  		it should be an function callable on an iterable.
  		"""
  		if hasattr(outpipe, '__pipe__'):
  			return outpipe.__pipe__(inpipe)
  		elif hasattr(outpipe, '__call__'):
  			return outpipe(inpipe)
  		else:
  			raise BrokenPipe('No connection mechanism defined')