Describe the Request

Neither the StreamProducer nor StreamConsumer are containers so I don't think we need the classes to be generic on the Publisher/Subscriber nor Connector.

Sample Code

No response