#524

Build # #524

Build Type

push

Committed by

Commit Message

<a href="https://github.com/evolution-gaming/skafka/commit/<a class=hub.com/evolution-gaming/skafka/commit/fb5476b132c56e2d0eb8f501d52664828cf6b2e8">fb5476b13<a href="https://github.com/evolution-gaming/skafka/commit/fb5476b132c56e2d0eb8f501d52664828cf6b2e8">">Merge </a><a class="double-link" href="https://github.com/evolution-gaming/skafka/commit/<a class="double-link" href="https://github.com/evolution-gaming/skafka/commit/ff270b8bef9cab0c697d3c597953d7484cc46390">ff270b8be</a>">ff270b8be</a><a href="https://github.com/evolution-gaming/skafka/commit/fb5476b132c56e2d0eb8f501d52664828cf6b2e8"> into b76b257d5">b76b257d5</a>

Run Details

90 of 90 new or added lines in 6 files covered. (100.0%)

1044 of 1200 relevant lines covered (87.0%)

0.87 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

37.5

/skafka/src/main/scala/com/evolutiongaming/skafka/consumer/RebalanceListener1.scala

package com.evolutiongaming.skafka.consumer

import cats.data.{NonEmptySet => Nes}
import cats.~>
import com.evolutiongaming.skafka.TopicPartition

/**
  * Will be converted to [[org.apache.kafka.clients.consumer.ConsumerRebalanceListener]] during consumer.subscribe
  * // TODO add most common usages in scaladoc from spec (using position/seek/commit)
  * // TODO rename to something more meaningful vs just appending `1` to existing name `RebalanceListener`
  * see [[com.evolutiongaming.skafka.consumer.RebalanceCallback]]
  */
trait RebalanceListener1[F[_]] { self =>

  def onPartitionsAssigned(partitions: Nes[TopicPartition]): RebalanceCallback[F, Unit]

  def onPartitionsRevoked(partitions: Nes[TopicPartition]): RebalanceCallback[F, Unit]

  def onPartitionsLost(partitions: Nes[TopicPartition]): RebalanceCallback[F, Unit]

}

object RebalanceListener1 {
  def noOp[F[_]]: RebalanceListener1[F] =
    new RebalanceListener1[F] {

      def onPartitionsAssigned(
        partitions: Nes[TopicPartition]
      ): RebalanceCallback[F, Unit] = RebalanceCallback.noOp

      def onPartitionsRevoked(
        partitions: Nes[TopicPartition]
      ): RebalanceCallback[F, Unit] = RebalanceCallback.noOp

      def onPartitionsLost(
        partitions: Nes[TopicPartition]
      ): RebalanceCallback[F, Unit] = RebalanceCallback.noOp

    }

  implicit class RebalanceListener1Ops[F[_]](val self: RebalanceListener1[F]) extends AnyVal {

    def mapK[G[_]](fg: F ~> G): RebalanceListener1[G] = new RebalanceListener1[G] {

      def onPartitionsAssigned(partitions: Nes[TopicPartition]): RebalanceCallback[G, Unit] =
        self.onPartitionsAssigned(partitions).mapK(fg)

      def onPartitionsRevoked(partitions: Nes[TopicPartition]): RebalanceCallback[G, Unit] =
        self.onPartitionsRevoked(partitions).mapK(fg)

      def onPartitionsLost(partitions: Nes[TopicPartition]): RebalanceCallback[G, Unit] =
        self.onPartitionsLost(partitions).mapK(fg)
    }

  }
}

1	package com.evolutiongaming.skafka.consumer
2
3	import cats.data.{NonEmptySet => Nes}
4	import cats.~>
5	import com.evolutiongaming.skafka.TopicPartition
6
7	/**
8	* Will be converted to [[org.apache.kafka.clients.consumer.ConsumerRebalanceListener]] during consumer.subscribe
9	* // TODO add most common usages in scaladoc from spec (using position/seek/commit)
10	* // TODO rename to something more meaningful vs just appending `1` to existing name `RebalanceListener`
11	* see [[com.evolutiongaming.skafka.consumer.RebalanceCallback]]
12	*/
13	trait RebalanceListener1[F[_]] { self =>
14
15	def onPartitionsAssigned(partitions: Nes[TopicPartition]): RebalanceCallback[F, Unit]
16
17	def onPartitionsRevoked(partitions: Nes[TopicPartition]): RebalanceCallback[F, Unit]
18
19	def onPartitionsLost(partitions: Nes[TopicPartition]): RebalanceCallback[F, Unit]
20
21	}
22
23	object RebalanceListener1 {
24	def noOp[F[_]]: RebalanceListener1[F] =
25	new RebalanceListener1[F] {	×
26
27	def onPartitionsAssigned(
28	partitions: Nes[TopicPartition]
29	): RebalanceCallback[F, Unit] = RebalanceCallback.noOp	×
30
31	def onPartitionsRevoked(
32	partitions: Nes[TopicPartition]
33	): RebalanceCallback[F, Unit] = RebalanceCallback.noOp	×
34
35	def onPartitionsLost(
36	partitions: Nes[TopicPartition]
37	): RebalanceCallback[F, Unit] = RebalanceCallback.noOp	×
38
39	}
40
41	implicit class RebalanceListener1Ops[F[_]](val self: RebalanceListener1[F]) extends AnyVal {
42
43	def mapK[G[_]](fg: F ~> G): RebalanceListener1[G] = new RebalanceListener1[G] {	1✔
44
45	def onPartitionsAssigned(partitions: Nes[TopicPartition]): RebalanceCallback[G, Unit] =
46	self.onPartitionsAssigned(partitions).mapK(fg)	1✔
47
48	def onPartitionsRevoked(partitions: Nes[TopicPartition]): RebalanceCallback[G, Unit] =
49	self.onPartitionsRevoked(partitions).mapK(fg)	1✔
50
51	def onPartitionsLost(partitions: Nes[TopicPartition]): RebalanceCallback[G, Unit] =
52	self.onPartitionsLost(partitions).mapK(fg)	×
53	}
54
55	}
56	}

evolution-gaming / skafka / #524

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous