val outputListing: FullListing = //...
val inputListing: RawListing = //...
val save = new MemorySink[ListingResults]
val processor = new ListingProcessor(_ => Task.now(Some(outputListing)), save)
processor.processListing(Seq(inputListing))
// resolve asynchrony
save.last should beSome(Seq(outputListing))
/decorator9.md
Created May 28, 2018
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment