abort sub by throw an timax::rpc::exception

purecpp-org · Oct 12, 2016 · c0edcf7 · c0edcf7
1 parent 6771ef8
commit c0edcf7
Showing 1 changed file with 11 additions and 1 deletion.
diff --git a/rest_rpc/client/detail/async_sub_session.hpp b/rest_rpc/client/detail/async_sub_session.hpp
@@ -234,7 +234,17 @@ namespace timax { namespace rpc
 			if (!error)
 			{
 				if (function_)
-					function_(response_.data(), response_.size());
+				{
+					try
+					{
+						function_(response_.data(), response_.size());
+					}
+					catch (exception const& error)
+					{
+						on_error(error);
+						return;
+					}
+				}
 
 				recv_sub_head();
 			}