Some refactorings Added counterpart of existing rsocket connection controller that is based on kotlin coroutines and actor model