{"action":"created","issue":{"url":"https://api.github.com/repos/krasserm/akka-persistence-kafka/issues/24","labels_url":"https://api.github.com/repos/krasserm/akka-persistence-kafka/issues/24/labels{/name}","comments_url":"https://api.github.com/repos/krasserm/akka-persistence-kafka/issues/24/comments","events_url":"https://api.github.com/repos/krasserm/akka-persistence-kafka/issues/24/events","html_url":"https://github.com/krasserm/akka-persistence-kafka/issues/24","id":71925753,"number":24,"title":"Write messages","user":{"login":"giena","id":6929360,"avatar_url":"https://avatars.githubusercontent.com/u/6929360?v=3","gravatar_id":"","url":"https://api.github.com/users/giena","html_url":"https://github.com/giena","followers_url":"https://api.github.com/users/giena/followers","following_url":"https://api.github.com/users/giena/following{/other_user}","gists_url":"https://api.github.com/users/giena/gists{/gist_id}","starred_url":"https://api.github.com/users/giena/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/giena/subscriptions","organizations_url":"https://api.github.com/users/giena/orgs","repos_url":"https://api.github.com/users/giena/repos","events_url":"https://api.github.com/users/giena/events{/privacy}","received_events_url":"https://api.github.com/users/giena/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":2,"created_at":"2015-04-29T16:39:38Z","updated_at":"2015-04-30T09:12:15Z","closed_at":null,"body":"The asyncWriteMessages is like this: \r\ndef asyncWriteMessages(messages: Seq[PersistentRepr]): Future[Unit] = {\r\n    val sends = messages.groupBy(_.persistenceId).map {\r\n      case (pid, msgs) => writerFor(pid).ask(messages)(writeTimeout)\r\n    }\r\n    Future.sequence(sends).map(_ => ())\r\n  }\r\n\r\nI think it should be like this:\r\ndef asyncWriteMessages(messages: Seq[PersistentRepr]): Future[Unit] = {\r\n    val sends = messages.groupBy(_.persistenceId).map {\r\n      case (pid, msgs) => writerFor(pid).ask(msgs)(writeTimeout)\r\n    }\r\n    Future.sequence(sends).map(_ => ())\r\n  }\r\n\r\nDo i make a mistake?"},"comment":{"url":"https://api.github.com/repos/krasserm/akka-persistence-kafka/issues/comments/97715182","html_url":"https://github.com/krasserm/akka-persistence-kafka/issues/24#issuecomment-97715182","issue_url":"https://api.github.com/repos/krasserm/akka-persistence-kafka/issues/24","id":97715182,"user":{"login":"giena","id":6929360,"avatar_url":"https://avatars.githubusercontent.com/u/6929360?v=3","gravatar_id":"","url":"https://api.github.com/users/giena","html_url":"https://github.com/giena","followers_url":"https://api.github.com/users/giena/followers","following_url":"https://api.github.com/users/giena/following{/other_user}","gists_url":"https://api.github.com/users/giena/gists{/gist_id}","starred_url":"https://api.github.com/users/giena/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/giena/subscriptions","organizations_url":"https://api.github.com/users/giena/orgs","repos_url":"https://api.github.com/users/giena/repos","events_url":"https://api.github.com/users/giena/events{/privacy}","received_events_url":"https://api.github.com/users/giena/received_events","type":"User","site_admin":false},"created_at":"2015-04-30T09:12:15Z","updated_at":"2015-04-30T09:12:15Z","body":"I've created a pull request: https://github.com/krasserm/akka-persistence-kafka/pull/25\r\nBut no test.\r\n"}}