From b005637b67960fc621d94e58930587661a9db553 Mon Sep 17 00:00:00 2001 From: Luka Rahne Date: Wed, 20 Oct 2021 21:09:21 +0200 Subject: [PATCH] Issue #49: Test for forwarding socket exceptions --- test/error_test.dart | 22 +++++++++++++++++----- 1 file changed, 17 insertions(+), 5 deletions(-) diff --git a/test/error_test.dart b/test/error_test.dart index ac805f7..cd3dd17 100644 --- a/test/error_test.dart +++ b/test/error_test.dart @@ -2,23 +2,35 @@ import 'package:redis/redis.dart'; import 'package:test/test.dart'; import 'main.dart'; +import 'dart:io'; + +Future generate_connect_broken() { + return RedisConnection().connect("localhost", 2); +} main() { group("Throw received Redis Errors", () { test("Expect error when sending Garbage", () async { Command cmd = await generate_connect(); - - expect(cmd.send_object("GARBAGE"), throwsA(isRedisError)); + expect(() => cmd.send_object("GARBAGE"), throwsA(isRedisError)); }); }); group("Recover after received Redis Errors", () { test("Expect error when sending Garbage 2", () async { Command cmd = await generate_connect(); - expect(cmd.send_object(["GARBAGE"]), throwsA(isRedisError)); + expect(() => cmd.send_object(["GARBAGE"]), throwsA(isRedisError)); // next two commands over same connection should be fine - expect(await cmd.send_object(["SET","garbage_test","grb"]),equals("OK")); - expect(await cmd.send_object(["GET","garbage_test"]),equals("grb")); + var ok = await cmd.send_object(["SET", "garbage_test", "grb"]); + expect(ok, equals("OK")); + var v = await cmd.send_object(["GET", "garbage_test"]); + expect(v, equals("grb")); + }); + }); + + group("Handle low lewel error", () { + test("handle error that is out of our contoll", () { + expect(generate_connect_broken, throwsA(isA())); }); }); }