Each P2PSP final application has a different way to implement the interaction between the consumer of the stream and the producer of the stream (a peer). In the case of p2psp-console, we will use a TCP socket for each consumer. This functionality should be moved from the core (which should only use abstract methods) to here.