func (client *Client) Message() (*Message, error) {

	for true {
		packet, message, err := client.Packet()
		if message != nil || err != nil || packet == nil {
			return message, err
		}
	}
	return nil, nil // unreachable
}
// Message waits for a incomming publish.
Message waits for a incomming publish.
// Message waits for a incomming publish .
func (client *Client) Message() (*Message, error) {
	for true {
		packet, message, err := client.Packet()
		if message != nil || err != nil || packet == nil {
			return message, err
		}
	}
	return nil, nil 
}
func ( client * Client ) Message ( ) ( * Message , error ) { for true { packet , message , err := client . Packet ( ) if message != nil || err != nil || packet == nil { return message , err } } return nil , nil }
Message waits for a incomming publish.
Message waits for a incomming publish .
// unreachable