Use keySet method to get keys of WeakHashMap
Implemented async zip function
Use blocking >!! for pushing into event stream
Added proper async map function