move tcp_acceptor to a header
move observable_source to a header
remove an unused class
move socket_observable to a header
move flatten to a header
move sending_observable to a header