connect method

@override Future<void> connect()

Implementation

@override
Future<void> connect() async {
  _replyStream = _client.signal(_requestStream.stream);
  _replyStream.listen(_onSignalReply,
      onDone: () => onclose?.call(0, 'closed'),
      onError: (e) => onclose?.call(500, '$e'));
  onready?.call();
}