Implementing custom unicast function so that observable -> enumerator will create a thread safe enumerator