I am trying to write to the DB in parallel using scalaz-stream.
Before I've done it with the set of actors, which would own connection each, and they would be pinned to the thread, so if connection dies the actor gets restarted, etc.
I really like scalaz-streams and would like to be able to achieve similar semantics with the library but I am a total newbie.
Any ideas?
Peter