@Override
    public RFuture<Void> removeListenerAsync(int listenerId) {
        RFuture<Void> f1 = removeTrackingListenerAsync(listenerId);
        RFuture<Void> f2 = removeListenerAsync(listenerId, "__keyevent@*:set");
        return new CompletableFutureWrapper<>(CompletableFuture.allOf(f1.toCompletableFuture(), f2.toCompletableFuture()));
    }
@Test
    public void testRemoveListenerAsync() {
        testWithParams(redisson -> {
            RBucket<Integer> al = redisson.getBucket("test");
            int id = al.addListenerAsync(new SetObjectListener() {
                @Override
                public void onSet(String name) {
                }
            }).toCompletableFuture().join();
            al.removeListenerAsync(id).toCompletableFuture().join();
        }, NOTIFY_KEYSPACE_EVENTS, "E$");
    }