val outputListing: FullListing = //...
val inputListing: RawListing = //...
val save = new MemorySink[ListingResults] // MemorySink[A] extends Sink[Id,A] now
val processor = new ListingProcessor[Id](_ => Some(outputListing), save)
processor.processListing(Seq(inputListing))
save.last should beSome(Seq(outputListing))
Last active
May 28, 2018 06:11
-
-
Save wjlow/a2787bd2ec862115acbed82ec0fedcc6 to your computer and use it in GitHub Desktop.
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment