@@ -354,6 +354,7 @@ public async Task Given_content_type_not_equal_to_eventstream_when_the_http_resp
354354 var evt = new EventSource ( config ) ;
355355
356356 var receiver = new ErrorReceiver ( evt ) ;
357+ receiver . CloseEventSourceOnError = true ;
357358
358359 //// Act
359360 await evt . StartAsync ( ) ;
@@ -375,6 +376,7 @@ public async Task Given_204_when_the_http_response_is_received_then_error_event_
375376 var evt = new EventSource ( new Configuration ( _uri , handler ) ) ;
376377
377378 var receiver = new ErrorReceiver ( evt ) ;
379+ receiver . CloseEventSourceOnError = true ;
378380
379381 //Act
380382 await evt . StartAsync ( ) ;
@@ -402,6 +404,7 @@ public async Task Given_status_code_when_the_http_response_is_received_then_erro
402404 var evt = new EventSource ( new Configuration ( _uri , handler ) ) ;
403405
404406 ErrorReceiver receiver = new ErrorReceiver ( evt ) ;
407+ receiver . CloseEventSourceOnError = true ;
405408
406409 await evt . StartAsync ( ) ;
407410
@@ -469,6 +472,7 @@ public async Task When_response_exceeds_read_timeout_then_read_timeout_exception
469472 var evt = new StubEventSource ( new Configuration ( _uri , handler , readTimeout : readTimeout ) , ( int ) timeout . TotalMilliseconds ) ;
470473
471474 var receiver = new ErrorReceiver ( evt ) ;
475+ receiver . CloseEventSourceOnError = true ;
472476
473477 await evt . StartAsync ( ) ;
474478
@@ -519,8 +523,7 @@ public async Task When_server_returns_HTTP_error_a_reconnect_attempt_is_made()
519523
520524 var evt = new EventSource ( new Configuration ( _uri , handler ) ) ;
521525
522- ErrorReceiver receiver = new ErrorReceiver ( evt ) ;
523- receiver . CloseEventSourceOnError = false ;
526+ var receiver = new ErrorReceiver ( evt ) ;
524527
525528 string messageReceived = null ;
526529 evt . MessageReceived += ( _ , e ) =>
@@ -547,6 +550,7 @@ public async Task When_error_handler_closes_event_source_no_reconnect_attempt_is
547550 var evt = new EventSource ( new Configuration ( _uri , handler ) ) ;
548551
549552 var receiver = new ErrorReceiver ( evt ) ;
553+ receiver . CloseEventSourceOnError = true ;
550554
551555 await evt . StartAsync ( ) ;
552556
@@ -556,7 +560,7 @@ public async Task When_error_handler_closes_event_source_no_reconnect_attempt_is
556560
557561 class ErrorReceiver
558562 {
559- public bool CloseEventSourceOnError = true ;
563+ public bool CloseEventSourceOnError = false ;
560564 public Exception ErrorReceived = null ;
561565 public ReadyState SourceStateReceived ;
562566 private readonly EventSource _source ;
0 commit comments