That wont work with Storm. I need T=>Future[Unit] for it to work with Storm see https://github.com/twitter/summingbird/blob/develop/summingbird-storm/src/main/scala/com/twitter/summingbird/storm/StormPlatform.scala#L119