LoadBalancedRSocketMono refresh problem after new Collection<RSocketSupplier>

[linux-china]

Steps as following:

• create a rsocketSupplierProcessor with initial RSocket cluster information
• create LoadBalancedRSocketMono from rsocketSupplierProcessor
• invoke rsocketSupplierProcessor.onNext() to update RSocket cluster information

LoadBalancedRSocketMono will not work after cluster information updated. Maybe refreshSockets() not invoked after cluster updated.

        // rsocket cluster
        List<String> uriList1 = Arrays.asList("tcp://127.0.0.1:42252");
        ReplayProcessor<List<RSocketSupplier>> rsocketSupplierProcessor = ReplayProcessor.cacheLast();
        rsocketSupplierProcessor.onNext(uriList1.stream().map(uri -> new RSocketSupplier(() -> rSocket(uri))).collect(Collectors.toList()));
        LoadBalancedRSocketMono rSocketMono = LoadBalancedRSocketMono.create(rsocketSupplierProcessor);
        //update rsocket cluster,  the update logic in io.rsocket.client.RSocketSupplierPool.handleNewFactories
        // handleNewFactories does not invoke io.rsocket.client.LoadBalancedRSocketMono.refreshSockets();
        List<String> uriList2 = Arrays.asList("tcp://localhost:42252");
        rsocketSupplierProcessor.onNext(uriList2.stream().map(uri -> new RSocketSupplier(() -> rSocket(uri))).collect(Collectors.toList()));
       

[robertroeser]

Is this a duplicate of #633 ?

[jareddellitt]

I think this is the same thing I addressed in #623. Any chance a new RC will be published soon with the fix?

[robertroeser]

@jareddellitt @linux-china 0.12.2-RC3 is out

[linux-china]

@robertroeser yes, it works for me with 0.12.2-RC3 :)