def createStream()

in src/it/scala/com/gu/kinesis/KinesisResourceManager.scala [37:54]

• 18 lines of code
• 1 McCabe index (conditional complexity)

  def createStream(regionName: String, streamName: String, shardCount: Int): StreamDescription = {
    withKinesisClient(regionName) { client =>
      client.createStream(
        CreateStreamRequest
          .builder()
          .streamName(streamName)
          .shardCount(shardCount)
          .build()
      )
      eventually(timeout(CreateStreamTimeout), interval(2.second)) {
        val description = client
          .describeStream(DescribeStreamRequest.builder().streamName(streamName).build())
          .streamDescription()
        require(description.streamStatusAsString() == "ACTIVE")
        description
      }
    }
  }