1
1
package org .virtuslab .ash .circe
2
2
3
- import akka .actor
3
+ // scalafix:off
4
+ import akka .actor .{ActorSystem => ClassicActorSystem }
4
5
import akka .actor .typed .ActorRef
5
6
import akka .actor .typed .ActorRefResolver
6
7
import akka .actor .typed .ActorSystem
@@ -11,28 +12,29 @@ import akka.stream.StreamRefResolver
11
12
import io .circe .Codec
12
13
import io .circe .Decoder
13
14
import io .circe .Encoder
15
+ // scalafix:on
14
16
15
17
/**
16
18
* Default codecs for serializing some of Akka types
17
19
*/
18
20
trait AkkaCodecs {
19
- private def serializationSystem : actor. ActorSystem = Serialization .getCurrentTransportInformation().system
21
+ private def serializationSystem : ClassicActorSystem = Serialization .getCurrentTransportInformation().system
20
22
21
- implicit def actorRefCodec [T ](implicit system : actor. ActorSystem = serializationSystem): Codec [ActorRef [T ]] = {
23
+ implicit def actorRefCodec [T ](implicit system : ClassicActorSystem = serializationSystem): Codec [ActorRef [T ]] = {
22
24
val resolver = ActorRefResolver (ActorSystem .wrap(system))
23
25
Codec .from(
24
26
Decoder .decodeString.map(resolver.resolveActorRef),
25
27
Encoder .encodeString.contramap(resolver.toSerializationFormat))
26
28
}
27
29
28
- implicit def sinkRefCodec [T ](implicit system : actor. ActorSystem = serializationSystem): Codec [SinkRef [T ]] = {
30
+ implicit def sinkRefCodec [T ](implicit system : ClassicActorSystem = serializationSystem): Codec [SinkRef [T ]] = {
29
31
val resolver = StreamRefResolver (ActorSystem .wrap(system))
30
32
Codec .from(
31
33
Decoder .decodeString.map(resolver.resolveSinkRef),
32
34
Encoder .encodeString.contramap(resolver.toSerializationFormat(_ : SinkRef [T ])))
33
35
}
34
36
35
- implicit def sourceRefCodec [T ](implicit system : actor. ActorSystem = serializationSystem): Codec [SourceRef [T ]] = {
37
+ implicit def sourceRefCodec [T ](implicit system : ClassicActorSystem = serializationSystem): Codec [SourceRef [T ]] = {
36
38
val resolver = StreamRefResolver (ActorSystem .wrap(system))
37
39
Codec .from(
38
40
Decoder .decodeString.map(resolver.resolveSourceRef),
0 commit comments