File tree Expand file tree Collapse file tree 1 file changed +0
-12
lines changed
src/main/scala/com/intenthq/action_processor/integrationsV2 Expand file tree Collapse file tree 1 file changed +0
-12
lines changed Original file line number Diff line number Diff line change @@ -11,10 +11,6 @@ import scala.jdk.CollectionConverters._
11
11
12
12
abstract class CsvFeed [O ] extends Feed [Iterable [String ], O ] {
13
13
14
- // protected val csvResource: String
15
-
16
- // private lazy val typeFactory = new ReflectionHelpers.CaseClassFactory[I]
17
-
18
14
protected lazy val csvReader : CsvReader = new CsvReader
19
15
20
16
protected def rows : Stream [IO , String ]
@@ -29,12 +25,4 @@ abstract class CsvFeed[O] extends Feed[Iterable[String], O] {
29
25
30
26
override def inputStream : Stream [IO , Iterable [String ]] =
31
27
rows.evalMap(csvParse)
32
-
33
- // protected def fromString: fs2.Pipe[IO, Iterable[String], I] =
34
- // sourceStream => {
35
- // sourceStream.evalMap { line =>
36
- // val params = .productIterator.toList
37
- // IO(typeFactory.buildWith(params))
38
- // }
39
- // }
40
28
}
You can’t perform that action at this time.
0 commit comments