r2dbc / r2dbc-pool

Connection Pooling for Reactive Relational Database Connectivity
https://r2dbc.io
Apache License 2.0
331 stars 55 forks source link

io.r2dbc.spi.Result.getRowsUpdated #185

Closed Lovecxgood closed 1 year ago

Lovecxgood commented 1 year ago

io.r2dbc.spi.Result.getRowsUpdated can not return a affected num in version 1.0.0.RELEASE no signal was emited like onerror oncompleted onnext version 0.9.2.RELEASE is ok

            public void onNext(Result t) {
                t.getRowsUpdated().subscribe(new TSubscriber<Long>() {
                    @Override
                    public void onSubscribe(Subscription s) {
                        s.request(1);
                    }

                    @Override
                    public void onNext(Long t) {
                        num = t.intValue();
                    }
                });
            }
mp911de commented 1 year ago

If you would like us to spend some time helping you to diagnose the problem, please spend some time describing it and, ideally, providing a minimal sample that reproduces the problem.