s3.scala

 
    val store =
      Stream.bracket(IO(AmazonS3ClientBuilder.standard().build()))(
        c => Stream.emit(S3Store[IO](c)),
        a => IO(a.shutdown())
      )

    val prog1 =
      store.flatMap { s3 =>
        s3.list(Path("org.tpolecat.test1"))
          .map(_.toString)
          .through(text.utf8Encode)
          .to(io.stdout)
      }

    val prog2 =
      store.flatMap { s3 =>
        Stream("hello")
          .covary[IO]
          .through(text.utf8Encode)
          .to(s3.put(Path("org.tpolecat.test1/foo")))
      }


    prog1.compile.drain.unsafeRunSync // works, lists contents of bucket
    prog2.compile.drain.unsafeRunSync // warns about content size and then hangs