How to crash on failure?

[njlr]

When I reach this state:

fail: Streamiz.Kafka.Net.Processors.StreamStateManager[0]
All stream threads have died. The instance will be in error state and should be closed

I would like the program to crash.

I start the program with stream.StartAsync()

Is there an equivalent like stream.WaitForEndAsync()?

[LGouellec]

You can configure your InnerExceptionHandler to kill your app by yourself.

config.InnerExceptionHandler

[njlr]

After calling stream.StartAsync(), is there a way to get a task that throws an exception when the config.InnerExceptionHandler receives ExceptionHandlerResponse.FAIL?

[LGouellec]

@njlr No, 'config.InnerExceptionHandler'. is called by an internal background thread. You should refer to the state of the stream to know if the stream has failed or not

[njlr]

@njlr No, 'config.InnerExceptionHandler'. is called by an internal background thread. You should refer to the state of the stream to know if the stream has failed or not

Is there an example of this?

My current attempt using a StateListener:

var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);

var listener = new StateListener((sender, newState) =>
    {
        if (newState.Name == "ERROR" || newState.Name == "CLOSED")
        {
            // Use TrySetResult to avoid exceptions if called multiple times
            tcs.TrySetResult();
        }
    });

stream.add_StateChanged(listener);

// Now wait for the tcs

[LGouellec]

@njlr Looks good !

[njlr]

@njlr Looks good !

Except it doesn't work! The process does not terminate.