remove ListenableFuture from surface#1599
remove ListenableFuture from surface#1599pongad merged 4 commits intogoogleapis:masterfrom pongad:listenable
Conversation
This won't compile yet, since it needs change in gax: googleapis/gax-java#198
| void receiveMessage(final PubsubMessage message, final SettableFuture<AckReply> response); | ||
| interface AckReplyConsumer { | ||
| void accept(AckReply ackReply, Throwable t); | ||
| } |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
| * Accepts a reply, sending it to the service. | ||
| * | ||
| * <p>Both the interface and its method is named after the Java 8's {@code BiConsumer} interface | ||
| * to ease migration when we finally move. |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
| return new ListenableFutureDelegate<String>(publishResult); | ||
| } | ||
|
|
||
| private static class ListenableFutureDelegate<V> extends SimpleForwardingListenableFuture<V> |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
|
@garrettjonesgoogle PTAL |
garrettjonesgoogle
left a comment
There was a problem hiding this comment.
LGTM after the new GAX is released and the tests pass
| package com.google.cloud.pubsub.spi.v1; | ||
|
|
||
| /** | ||
| * Used by {@link MessageReceiver}, {@code AckReplyConsumer} accepts an {@link MessageReceiver.AckReply}, sending it to the service. |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
|
In the future I think it would be easier to do a PR first against |
|
LGTM |
#1599) * chore: Update generation configuration at Wed Sep 25 02:24:24 UTC 2024 * update gen script * chore: generate libraries at Wed Sep 25 23:31:54 UTC 2024 * chore: Update generation configuration at Thu Sep 26 02:23:26 UTC 2024 * chore: Update generation configuration at Fri Sep 27 02:23:56 UTC 2024 * chore: Update generation configuration at Sat Sep 28 02:22:38 UTC 2024 --------- Co-authored-by: Joe Wang <joewa@google.com>
…v3.56.1 (#1599) Co-authored-by: Jin Seop Kim <1007sky@gmail.com>
This won't compile yet, since it needs change in gax:
googleapis/gax-java#200