Exceptions which fire within Response.Send() cause entire app to exit

[wildbunny]

e.g. changing the code to this:

WriteStream(listenerResponse.OutputStream)
.Subscribe(s =>
{
    try
    {
        s.Close();

        throw new System.Net.Sockets.SocketException();

will cause the entire app to exit. Would be nice to pass any exceptions back up the chain for handling via the app itself.

[kawazoe]

Since Anna is based on Rx, it assumes that you repect the Rx ways of doing things. You should not do any "heavy lifting" inside the Subscribe method. Instead, you should handle such cases upward in the observable chain so that exceptions get sent in the error channel. You can take a look at how this can be done here: https://github.com/FurryBuilder/FluffIt.System.Reactive/blob/master/FluffIt.System.Reactive/ObservableExtensions.cs#L98