session

type Handler struct {
	// Ch is used to send recieved values.
	Ch chan<- *MessageCloser

	// Done is used to indicate a session has expired or was otherwise
	// closed.
	Done chan<- struct{}
}

type HandlerFunc func(rpcid []byte) *Handler

type Manager struct {
	// contains filtered or unexported fields
}

type MessageCloser struct {
	*core.Message
	io.Closer
}