Implement proper error handling for akka-streams

Make AdapterPublisher and AdapterSubscriber extend common base-class
AdapterBase.

Add tests that actors are stopped