Refactor Observable and provide additional instances
Introduce a very simple node (connect/disconnect) monitoring agent