Merge pull request #618 from zhenlineo/2.0-improve-shaded-reactor

Avoid a queue for shaded record publisher

Author: zhenlineo

driver/src/main/java/org/neo4j/driver/internal/reactive/InternalRxStatementResult.java

@@ -26,11 +26,13 @@
 import java.util.function.Supplier;
 
 import org.neo4j.driver.Record;
+import org.neo4j.driver.internal.cursor.RxStatementResultCursor;
 import org.neo4j.driver.internal.util.Futures;
 import org.neo4j.driver.reactive.RxStatementResult;
-import org.neo4j.driver.internal.cursor.RxStatementResultCursor;
 import org.neo4j.driver.summary.ResultSummary;
 
+import static reactor.core.publisher.FluxSink.OverflowStrategy.IGNORE;
+
 public class InternalRxStatementResult implements RxStatementResult
 {
     private Supplier<CompletionStage<RxStatementResultCursor>> cursorFutureSupplier;
@@ -83,7 +85,7 @@ else if ( e != null )
                 Throwable error = Futures.completionExceptionCause( completionError );
                 sink.error( error );
             }
-        } ) );
+        } ), IGNORE );
     }
 
     private CompletionStage<RxStatementResultCursor> getCursorFuture()