Skip to content

Instantly share code, notes, and snippets.

@wjlow
Created May 28, 2018 06:09
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save wjlow/0e90521c0005fec931ce2a22a8b9ecf4 to your computer and use it in GitHub Desktop.
Save wjlow/0e90521c0005fec931ce2a22a8b9ecf4 to your computer and use it in GitHub Desktop.
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))
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment