replaced cypher-stream with my fork