Skip to content

Commit

Permalink
Fix failing test
Browse files Browse the repository at this point in the history
  • Loading branch information
graemerocher committed Dec 13, 2018
1 parent aa6dad3 commit 0aeb9ad
Showing 1 changed file with 2 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,7 @@
package io.micronaut.configuration.lettuce.cache;

import io.micronaut.cache.annotation.*;
import io.micronaut.core.async.annotation.SingleResult;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

Expand Down Expand Up @@ -63,6 +64,7 @@ public CompletableFuture<Integer> futureValue(String name) {
}

@Cacheable
@SingleResult
public Flux<Integer> flowableValue(String name) {
return Flux.just(counters.computeIfAbsent(name, (key)-> 0));
}
Expand Down

0 comments on commit 0aeb9ad

Please sign in to comment.