File tree Expand file tree Collapse file tree 4 files changed +8
-15
lines changed
jest/src/test/scala/app/softnetwork/elastic/persistence/person
rest/src/test/scala/app/softnetwork/elastic/persistence/person
testkit/src/main/scala/app/softnetwork/elastic/persistence Expand file tree Collapse file tree 4 files changed +8
-15
lines changed Original file line number Diff line number Diff line change @@ -2,15 +2,11 @@ package app.softnetwork.elastic.persistence.person
22
33import akka .actor .typed .ActorSystem
44import app .softnetwork .elastic .client .jest .JestClientApi
5- import app .softnetwork .elastic .persistence .query .ElasticProvider
5+ import app .softnetwork .elastic .persistence .query .{ ElasticProvider , PersonToElasticProcessorStream }
66import app .softnetwork .persistence .ManifestWrapper
7- import app .softnetwork .persistence .person .ElasticPersonTestKit
87import app .softnetwork .persistence .person .model .Person
98import app .softnetwork .persistence .person .query .PersonToExternalProcessorStream
10- import app .softnetwork .persistence .query .{
11- ExternalPersistenceProvider ,
12- PersonToElasticProcessorStream
13- }
9+ import app .softnetwork .persistence .query .ExternalPersistenceProvider
1410import com .typesafe .config .Config
1511import org .slf4j .{Logger , LoggerFactory }
1612
Original file line number Diff line number Diff line change @@ -2,15 +2,11 @@ package app.softnetwork.elastic.persistence.person
22
33import akka .actor .typed .ActorSystem
44import app .softnetwork .elastic .client .rest .RestHighLevelClientApi
5- import app .softnetwork .elastic .persistence .query .ElasticProvider
5+ import app .softnetwork .elastic .persistence .query .{ ElasticProvider , PersonToElasticProcessorStream }
66import app .softnetwork .persistence .ManifestWrapper
7- import app .softnetwork .persistence .person .ElasticPersonTestKit
87import app .softnetwork .persistence .person .model .Person
98import app .softnetwork .persistence .person .query .PersonToExternalProcessorStream
10- import app .softnetwork .persistence .query .{
11- ExternalPersistenceProvider ,
12- PersonToElasticProcessorStream
13- }
9+ import app .softnetwork .persistence .query .ExternalPersistenceProvider
1410import com .typesafe .config .Config
1511import org .slf4j .{Logger , LoggerFactory }
1612
Original file line number Diff line number Diff line change 1- package app .softnetwork .persistence .person
1+ package app .softnetwork .elastic . persistence .person
22
33import app .softnetwork .elastic .scalatest .EmbeddedElasticTestKit
4+ import app .softnetwork .persistence .person .PersonTestKit
45import app .softnetwork .persistence .scalatest .InMemoryPersistenceTestKit
56
67trait ElasticPersonTestKit
Original file line number Diff line number Diff line change 1- package app .softnetwork .persistence .query
1+ package app .softnetwork .elastic . persistence .query
22
33import app .softnetwork .elastic .client .ElasticClientApi
4- import app .softnetwork .elastic .persistence .query .{ElasticProvider , State2ElasticProcessorStream }
54import app .softnetwork .persistence .person .message .PersonEvent
65import app .softnetwork .persistence .person .model .Person
76import app .softnetwork .persistence .person .query .PersonToExternalProcessorStream
7+ import app .softnetwork .persistence .query .{InMemoryJournalProvider , InMemoryOffsetProvider }
88
99trait PersonToElasticProcessorStream
1010 extends State2ElasticProcessorStream [Person , PersonEvent ]
You can’t perform that action at this time.
0 commit comments