Create a new low-level publisher stream manager that maintains the open publish stream and allows users to publish events and receive acks/nacks from the Ensign node.

Create a new low-level subscribe stream manager that maintains an open subscribe stream and allows user to send acks/nack back to the Ensign node.

Publisher wraps an stream.PublishClient to maintain an open publish stream to an Ensign node.

Subscriber wraps a stream.SubscribeClient to maintain an open subscribe stream to an Ensign node.