Skip to content

Commit e12e0ff

Browse files
committed
fix: Run scalafix on Monix and ZIO
1 parent ccd4be6 commit e12e0ff

File tree

3 files changed

+21
-13
lines changed

3 files changed

+21
-13
lines changed

monix/src/main/scala/net/nmoncho/helenus/monix/Package.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -21,10 +21,12 @@
2121

2222
package net.nmoncho.helenus.monix
2323

24+
import scala.annotation.targetName
2425
import scala.concurrent.ExecutionContext
2526
import scala.concurrent.Future
2627
import scala.concurrent.duration.FiniteDuration
2728
import scala.jdk.FutureConverters.*
29+
2830
import _root_.monix.eval.Task
2931
import _root_.monix.execution.Ack
3032
import _root_.monix.reactive.Consumer
@@ -38,8 +40,6 @@ import net.nmoncho.helenus.api.cql.ScalaPreparedStatement
3840
import net.nmoncho.helenus.api.cql.WrappedBoundStatement
3941
import net.nmoncho.helenus.internal.cql.*
4042

41-
import scala.annotation.targetName
42-
4343
extension [Out](wbs: WrappedBoundStatement[Out])
4444
/** An [[Observable]] reading from Cassandra */
4545
def asObservable()(using CqlSession): Observable[Out] =

zio/src/main/scala/net/nmoncho/helenus/zio/Package.scala

Lines changed: 13 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -22,19 +22,25 @@
2222
package net.nmoncho.helenus
2323
package zio
2424

25-
import _root_.zio.stream.{ ZSink, ZStream }
26-
import _root_.zio.{ Chunk, ZIO }
27-
import com.datastax.oss.driver.api.core.cql.{ BoundStatement, Row }
28-
import com.datastax.oss.driver.api.core.{ MappedAsyncPagingIterable, PagingIterable }
25+
import scala.collection.Factory
26+
import scala.util.Failure
27+
import scala.util.Success
28+
import scala.util.Try
29+
30+
import _root_.zio.Chunk
31+
import _root_.zio.ZIO
32+
import _root_.zio.stream.ZSink
33+
import _root_.zio.stream.ZStream
34+
import com.datastax.oss.driver.api.core.MappedAsyncPagingIterable
35+
import com.datastax.oss.driver.api.core.PagingIterable
36+
import com.datastax.oss.driver.api.core.cql.BoundStatement
37+
import com.datastax.oss.driver.api.core.cql.Row
2938
import net.nmoncho.helenus.ScalaBoundStatement
3039
import net.nmoncho.helenus.api.RowMapper
3140
import net.nmoncho.helenus.api.cql.*
3241
import net.nmoncho.helenus.internal.cql.*
3342
import net.nmoncho.helenus.zio.macros.ZIOCqlQueryInterpolation
3443

35-
import scala.collection.Factory
36-
import scala.util.{ Failure, Success, Try }
37-
3844
type ZPagingIterable[Out] =
3945
ZIO[ZCqlSession, CassandraException, PagingIterable[Out]]
4046

zio/src/main/scala/net/nmoncho/helenus/zio/macros/ZIOCqlQueryInterpolation.scala

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -21,17 +21,19 @@
2121

2222
package net.nmoncho.helenus.zio.macros
2323

24+
import scala.quoted.*
25+
2426
import com.datastax.oss.driver.api.core.ProtocolVersion
25-
import com.datastax.oss.driver.api.core.cql.{ BoundStatement, Row }
27+
import com.datastax.oss.driver.api.core.cql.BoundStatement
28+
import com.datastax.oss.driver.api.core.cql.Row
2629
import com.datastax.oss.driver.internal.core.util.Strings
2730
import net.nmoncho.helenus.api.RowMapper
2831
import net.nmoncho.helenus.api.`type`.codec.Codec
2932
import net.nmoncho.helenus.api.cql.WrappedBoundStatement
30-
import net.nmoncho.helenus.zio.{ CassandraException, ZCqlSession }
33+
import net.nmoncho.helenus.zio.CassandraException
34+
import net.nmoncho.helenus.zio.ZCqlSession
3135
import zio.ZIO
3236

33-
import scala.quoted.*
34-
3537
object ZIOCqlQueryInterpolation:
3638

3739
def cqlImpl(sc: Expr[StringContext], params: Expr[Seq[Any]])(using

0 commit comments

Comments
 (0)