Skip to content
This repository has been archived by the owner on May 9, 2023. It is now read-only.

Commit

Permalink
Fix rebase on v2.0.5 (#130)
Browse files Browse the repository at this point in the history
  • Loading branch information
guizmaii authored Jan 17, 2023
1 parent a4acd55 commit b0f36e9
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 18 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@ import zio.ZLayer
import zio.kafka.embedded.Kafka
import zio.test._

trait ZIOSpecWithKafka extends ZIOSpec[TestEnvironment with Kafka] with KafkaRandom {
trait ZIOSpecWithKafka extends ZIOSpec[TestEnvironment with Kafka] {

override val bootstrap: ZLayer[Any, Any, TestEnvironment with Kafka] =
testEnvironment ++ Kafka.embedded
Expand Down
18 changes: 1 addition & 17 deletions zio-kafka-test/src/test/scala/zio/kafka/ZIOKafkaSpec.scala
Original file line number Diff line number Diff line change
@@ -1,19 +1,3 @@
package zio.kafka

import zio.{ Task, ZIO }

import java.util.UUID

trait ZIOKafkaSpec extends ZIOSpecWithKafka {

def kafkaPrefix: String

def randomThing(prefix: String): Task[String] =
ZIO.attempt(UUID.randomUUID()).map(uuid => s"$prefix-$uuid")

def randomTopic: Task[String] = randomThing(s"$kafkaPrefix-topic")

def randomGroup: Task[String] = randomThing(s"$kafkaPrefix-group")

def randomClient: Task[String] = randomThing(s"$kafkaPrefix-client")
}
trait ZIOKafkaSpec extends ZIOSpecWithKafka with KafkaRandom

0 comments on commit b0f36e9

Please sign in to comment.