On error not triggered when listen connection terminated

[steven-sheehy]

Bug Report

Fails to trigger an onError when the database is stopped and using postgresql listen.

Versions

• Driver: 0.8.0.RELEASE
• Database: postgres:11.3-alpine
• Java: 11
• OS: MacOS

Current Behavior

Stack trace

// your stack trace here

Table schema

Input Code

-- your SQL here;

Steps to reproduce

Run JUnit test: R2dbcListenApplicationTests.testDisconnect():
https://github.com/steven-sheehy/r2dbc-listen

Input Code

// your code here;

Expected behavior/code

Possible Solution

• Trigger an onError immediately
• Attempt reconnect automatically within some timeout, then trigger an onError if unsuccessful

Additional context

[mp911de]

Probably it would make sense to send different signals when the connection was closed intentionally and unintentionally. If the server goes down, we should send onError. When the application gets shut down, then we would complete the stream normally (onComplete).

[mp911de]

That's fixed now.