working fine, no bugs
cleaned code
refactored socketsInit and how it handles the ready object, delays 100ms to avoid pushing/send issue when socket is closed abruptly
refactored the observer names to add a suffix be more clear like <listening> for sockets and <inbound> and <outbound> for consumers
add better examples two consumers and socket example and duplex example
David Kebler