Refactoring in Connection() and streams.*,
changes in streams.Aspects() - read docstring, new tests