Purely functional, effectful, resource-safe, concurrent streams for Scala