Package net.finmath.decryptionoracle.config

Class RxJavaConfig

java.lang.Object

net.finmath.decryptionoracle.config.RxJavaConfig

@Configuration
public class RxJavaConfig
extends Object

RxJava global error handler. Purpose: - Suppress RxJava "UndeliverableException" noise that happens when a websocket connection drops and RxJava tries to deliver an error after a stream has already been disposed. - Keep real / actionable errors visible. This is mostly cosmetics; it does not change listener behavior/security.

Author:

Christian Fries

Constructor Summary

Constructors

Constructor	Description
RxJavaConfig()

Method Summary

Modifier and Type	Method	Description
void	init()	setupRxJavaErrorHandler
void	onClosed()	Recognize closing of the application context.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

RxJavaConfig

public RxJavaConfig()

Method Details

onClosed

@EventListener(org.springframework.context.event.ContextClosedEvent.class)
public void onClosed()

Recognize closing of the application context.

init

@PostConstruct
public void init()

setupRxJavaErrorHandler