Skip to content

Instantly share code, notes, and snippets.

@wjlow wjlow/
Last active May 28, 2018

What would you like to do?
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)


save.last should beSome(Seq(outputListing))
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.