The locked state directory is not being cleaned up after a failed test

[monksy]

Because we aren't considering that the topology could fail, we're not cleaning up if there is a failure in running the topology.

Consider closing even if there was an exception to clean up the directory:

mockedstreams/src/main/scala/com/madewithtea/mockedstreams/MockedStreams.scala

Line 143 in 929849f

val result: T = f(driver)

[jpzk]

Very good point, will add it to the next release!