// Connect asynchronously and use `requester()` to get the requester
    class MyService {

        private var requester: RSocketRequester? = null

	    private suspend fun requester() = requester ?:
            RSocketRequester.builder().connectTcp("localhost", 7000).also { requester = it }

        suspend fun doSomething() = requester().route(...)
    }

	// Or block
    class MyService {

        private val requester: RSocketRequester = runBlocking {
		    RSocketRequester.builder().connectTcp("localhost", 7000)
	    }

        suspend fun doSomething() = requester.route(...)
    }