Close Connection after its Producer finished
Producer maintains state and propagates it to Connections.
Create manual producer – Command
Connection transforms and filters the value
Create empty Consumer and send him values from Connection
Implement Subscribing and create simple test for working Connection