Refactor CypherStream and TransactionStream into separate files
Working rollback