transaction discard #11

lib/connection.dart

@@ -38,26 +38,19 @@ class RedisConnection{
   //it just wait something to come from socket
   //it parse it and execute future
   Future _senddummy(){
-    Completer completer = new Completer();
-    _future = _future.then((_) =>
-        RedisParser.parseredisresponse(_stream)
-        .then((v) => completer.complete(v))
-        .catchError((e) {
-            completer.completeError(e);
-        })
-      );
-    return completer.future;
+    _future = _future.then((_) {
+        return RedisParser.parseredisresponse(_stream);
+    });
+    return _future;
   }
 
   // return future that complets
   // when all prevous _future finished
   Future _getdummy(){
-    Completer completer = new Completer.sync();
     _future = _future.then((_){
-        completer.complete("dummy data");
-      }
-    );
-    return completer.future;
+	    return "dummy data";
+    });
+    return _future;
   }
 
   Future _sendraw(List data){

lib/transaction.dart

@@ -43,6 +43,12 @@ class Transaction extends Command{
     }).catchError((error) => c.completeError(error));
     return c.future;
   }
+
+  Future discard(){
+    _overrided_command._connection = this._connection;
+    transaction_completed = true;
+    return super.send_object(["DISCARD"]);
+  }
 
   Future exec(){
     _overrided_command._connection = this._connection;

test/performance.dart

@@ -7,11 +7,11 @@ import 'main.dart';
 
 void main() {
   testing_performance(
-          test_muliconnections_con(100), "Multiple connections", 2000000)
+          test_muliconnections_con(100), "Multiple connections", 200000)
       .then(
           (_) => testing_performance(test_pubsub_performance, "PubSub", 200000))
       .then((_) =>
-          testing_performance(test_performance, "Raw Performance", 2000000))
+          testing_performance(test_performance, "Raw Performance", 200000))
       .then((_) => test_long_running(200000))
       .then((_) => print("Finished Performance Tests"))
       .then((_) => exit(0));