File tree Expand file tree Collapse file tree 1 file changed +2
-12
lines changed
persistence/src/main/scala/hmda/persistence/processing Expand file tree Collapse file tree 1 file changed +2
-12
lines changed Original file line number Diff line number Diff line change @@ -64,11 +64,7 @@ class HmdaFileParser(submissionId: SubmissionId) extends HmdaPersistentActor {
64
64
var state = HmdaFileParseState ()
65
65
var encounteredParsingErrors : Boolean = false
66
66
val manager = context.parent
67
- val statRef = for {
68
- stat <- (manager ? GetActorRef (SubmissionLarStats .name)).mapTo[ActorRef ]
69
- } yield {
70
- stat
71
- }
67
+ val statRef = (manager ? GetActorRef (SubmissionLarStats .name)).mapTo[ActorRef ]
72
68
73
69
var tsParsingDone : Boolean = false
74
70
var larParsingDone : Boolean = false
@@ -104,7 +100,7 @@ class HmdaFileParser(submissionId: SubmissionId) extends HmdaPersistentActor {
104
100
.zip(Source .fromIterator(() => Iterator .from(2 )))
105
101
.map {
106
102
case (lar, index) =>
107
- sendLar( lar)
103
+ statRef.map(_ ! lar)
108
104
LarCsvParser (lar, index)
109
105
}
110
106
.map {
@@ -173,11 +169,5 @@ class HmdaFileParser(submissionId: SubmissionId) extends HmdaPersistentActor {
173
169
context stop self
174
170
175
171
}
176
-
177
- private def sendLar (s : String ) {
178
- for {
179
- stat <- statRef
180
- } yield stat ! s
181
- }
182
172
}
183
173
You can’t perform that action at this time.
0 commit comments