Version 1.0.0.2

dart/samples/dartiverse_search/web/client.dart

 // Copyright (c) 2013, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 
 import 'dart:async';
 import 'dart:convert';
 import 'dart:html';
 
 
 class Client {
   static const Duration RECONNECT_DELAY = const Duration(milliseconds: 500);
 
+  bool connectPending = false;
   WebSocket webSocket;
   final DivElement log = new DivElement();
   SearchInputElement searchElement = querySelector('#q');
   DivElement statusElement = querySelector('#status');
   DivElement resultsElement = querySelector('#results');
 
   Client() {
     searchElement.onChange.listen((e) {
       search(searchElement.value);
       searchElement.value = '';
     });
     connect();
   }
 
   void connect() {
+    connectPending = false;
     webSocket = new WebSocket('ws://${Uri.base.host}:${Uri.base.port}/ws');
     webSocket.onOpen.first.then((_) {
       onConnected();
       webSocket.onClose.first.then((_) {
         print("Connection disconnected to ${webSocket.url}");
         onDisconnected();
       });
     });
     webSocket.onError.first.then((_) {
       print("Failed to connect to ${webSocket.url}. "
             "Please run bin/server.dart and try again.");
       onDisconnected();
     });
   }
 
   void onConnected() {
     setStatus('');
     searchElement.disabled = false;
     searchElement.focus();
     webSocket.onMessage.listen((e) {
       onMessage(e.data);
     });
   }
 
   void onDisconnected() {
+    if (connectPending) return;
+    connectPending = true;
+    setStatus('Disconnected - start \'bin/server.dart\' to continue');
     searchElement.disabled = true;
-    setStatus('Disconnected - start \'bin/server.dart\' to continue');
     new Timer(RECONNECT_DELAY, connect);
   }
 
   void setStatus(String status) {
     statusElement.innerHtml = status;
   }
 
 
   void onMessage(data) {
     var json = JSON.decode(data);
@@ skipping 32 matching lines @@
       'input': input
     };
     webSocket.send(JSON.encode(request));
   }
 }
 
 
 void main() {
   var client = new Client();
 }