Spring Webflux Async PostgreSQL Publisher Stops After First Result : <p>I am trying to replace a PostgreSQL database poller with the reactive asynchronous <a href="https://github.com/alaisi/postgres-async-driver" rel="noreferrer">postgres-async-driver</a> and stream newly inserted rows to a Spring 5 Webflux Reactive websocket client like <a href="https://stackoverflow.com/users/607357/josh-long">Josh Long</a>'s awesome example demoed <a href="https://stackoverflow.com/questions/48763126/reactive-websockets-with-spring-5-how-to-get-initial-message">here</a> and based on <a href="https://stackoverflow.com/users/1092077/s%C3%A9bastien-deleuze">Sébastien Deleuze's</a> <a href="https://github.com/joshlong/spring-reactive-playground/blob/master/src/main/java/playground/postgres/PostgresPersonRepository.java" rel="noreferrer">spring-reactive-playground</a>.</p>

<p>My <code>Publisher</code> obtains the first <code>row</code>, but then does not return subsequent rows.
Is the problem with my <code>Observable</code>, my <code>Publisher</code>, or with how I am using the postgres-async-driver <code>Db</code>?</p>

<pre><code>public Observable&lt;WebSocketMessage&gt; getObservableWSM(WebSocketSession session){
    return
        // com.github.pgasync.Db
        db.queryRows(sql)
        // ~RowMapper method
        .map(row -&gt; mapRowToDto(row))
        // serialize dto to String for websocket
        .map(dto -&gt; { return objectMapper.writeValueAsString(dto); })
        // finally, write to websocket session 
        .map(str -&gt; { return session.textMessage((String) str);
        });
}
</code></pre>

<p>Then, I wire the <code>Observable</code> into my <code>WebSocketHandler</code> using a <code>RxReactiveStream.toPublisher</code> converter:</p>

<pre><code>@Bean
WebSocketHandler dbWebSocketHandler() {
    return session -&gt; {
        Observable&lt;WebSocketMessage&gt; o = getObservableWSM(session);
        return session.send(Flux.from(RxReactiveStreams.toPublisher(o)));
    };
}
</code></pre>

<p>That will grab the first <code>row</code> from my <code>sql</code> statement, but no additional rows. How do I continue to stream additional rows? </p>

<p>Ideally, I think I want the PostgreSQL equivalent of a MongoDB <a href="https://stackoverflow.com/a/47456820/237225">Tailable cursor</a>.</p>
