[UPDATE] extract reduce from library. Update streams.
[UPDATE] extracted count stream.