Make Topic streams pipeable
Unsubscribe from topic in test
Merge pull request #124 from megawac/streams

Make Topic streams pipeable