diff --git a/cli/src/main/scala/net/kemitix/thorp/cli/Program.scala b/cli/src/main/scala/net/kemitix/thorp/cli/Program.scala index 0c0a8e3..43ebc27 100644 --- a/cli/src/main/scala/net/kemitix/thorp/cli/Program.scala +++ b/cli/src/main/scala/net/kemitix/thorp/cli/Program.scala @@ -31,8 +31,8 @@ trait Program { private def handleActions(archive: ThorpArchive, actions: Stream[Action]): IO[Stream[StorageQueueEvent]] = - actions.foldRight(Stream[IO[StorageQueueEvent]]()) { - (action, stream) => archive.update(action) ++ stream + actions.foldLeft(Stream[IO[StorageQueueEvent]]()) { + (stream, action) => archive.update(action) ++ stream }.sequence }