New returns a new instance of Server.

NewStreamReader returns a new instance of StreamReader.

Message is a message struct to be received/published.

Server is a wrapper for server listener.

StreamReader is the server listener that reads messages from the byte stream provided by io.Reader.

Listener is an interface for server listener.

Handler is a callback function to process messages from io.Reader.