Skip to content

Commit db7a18e

Browse files
Remove test code
1 parent cad4e0e commit db7a18e

File tree

1 file changed

+1
-18
lines changed

1 file changed

+1
-18
lines changed

src/main/java/oracle/r2dbc/impl/OracleStatementImpl.java

Lines changed: 1 addition & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -952,8 +952,7 @@ private JdbcStatement(PreparedStatement preparedStatement, Object[] binds) {
952952
* @return A publisher that emits the result of executing this statement
953953
*/
954954
final Publisher<OracleResultImpl> execute() {
955-
956-
if(true)return Flux.usingWhen(Mono.just(new ArrayList<>(1)),
955+
return Flux.usingWhen(Mono.just(new ArrayList<>(1)),
957956
results ->
958957
Mono.from(bind())
959958
.thenMany(executeJdbc())
@@ -962,22 +961,6 @@ final Publisher<OracleResultImpl> execute() {
962961
.onErrorResume(R2dbcException.class, r2dbcException ->
963962
Mono.just(createErrorResult(r2dbcException))),
964963
this::deallocate);
965-
966-
List<OracleResultImpl> results = new ArrayList<>(1);
967-
Publisher<OracleResultImpl> deallocate =
968-
Mono.defer(() -> Mono.from(deallocate(results)))
969-
.cast(OracleResultImpl.class);
970-
971-
return Flux.concatDelayError(
972-
Mono.from(bind())
973-
.thenMany(executeJdbc())
974-
.map(this::getWarnings)
975-
.doOnNext(results::add)
976-
.onErrorResume(R2dbcException.class, r2dbcException ->
977-
Mono.just(createErrorResult(r2dbcException))),
978-
deallocate)
979-
.doOnCancel(() ->
980-
Mono.from(deallocate).subscribe());
981964
}
982965

983966
/**

0 commit comments

Comments
 (0)