Refactoring towards new FlexibleMessageEndpoints
Added ObservableSink,-Source,-Map + Tests