Connects to the relay server and returns a stream of Message objects.
Future<Stream<Message>> connect();