[infinispan-issues] [JBoss JIRA] (ISPN-5850) Listener close might get ahead of last event

[Galder Zamarreño (JIRA)]

     [ https://issues.jboss.org/browse/ISPN-5850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Galder Zamarreño resolved ISPN-5850.
------------------------------------
    Fix Version/s:     (was: 8.1.0.Final)
       Resolution: Rejected


Same issue as ISPN-5848

> Listener close might get ahead of last event
> --------------------------------------------
>
>                 Key: ISPN-5850
>                 URL: https://issues.jboss.org/browse/ISPN-5850
>             Project: Infinispan
>          Issue Type: Sub-task
>            Reporter: Galder Zamarreño
>            Assignee: Galder Zamarreño
>
> In this example:
> {code}
>       FunctionalMap.ReadOnlyMap<String, String> readOnlyMap = CreateFunctionalMaps.ro();
>       FunctionalMap.WriteOnlyMap<String, String> writeOnlyMap = CreateFunctionalMaps.wo();
>       FunctionalMap.ReadWriteMap<String, String> readWriteMap = CreateFunctionalMaps.rw();
>       // `written` is a ReadEntryView of the written entry
>       try(AutoCloseable handler = writeOnlyMap.listeners().onWrite(written ->
>             System.out.printf("Written (via onWrite): %s%n", written.get()))) {
>          Map<String, String> entries = new HashMap<>();
>          entries.put("key1", "value1");
>          entries.put("key2", "value2");
>          writeOnlyMap.evalMany(entries, (v, writeView) -> writeView.set(v))
>             .get(); // Wait for completable future
>       }
>       AutoCloseable writeCloseHandler = writeOnlyMap.listeners().add(new WriteListener<String, String>() {
>          @Override
>          public void onWrite(ReadEntryView<String, String> written) {
>             System.out.printf("Written (via add): %s%n", written.get());
>          }
>       });
>       CompletableFuture<Void> f0 = writeOnlyMap.eval("key1", view -> view.set("new-value1"));
>       CompletableFuture<Void> f1 = f0.thenAccept(ignore ->
>          writeOnlyMap.eval("key2", view -> view.set("new-value2")));
>       CompletableFuture<Void> f2 = f1.thenAccept(ignore -> {
>          try {
>             writeCloseHandler.close();
>          } catch (Exception e) {
>             e.printStackTrace();  // TODO: Customise this generated block
>          }
>       });
>       f2.get(); // Wait for completable future
> {code}
> The output is:
> {code}
> Written (via onWrite): value1
> Written (via onWrite): value2
> Written (via add): new-value1
> {code}
> Even though the listener is closed after the 2nd new value has been modified, it seems like the close might get ahead somehow.



--
This message was sent by Atlassian JIRA
(v6.4.11#64026)