From d2e35b0d0298c6c169ea5c50a5adf00cf721c71a Mon Sep 17 00:00:00 2001 From: nabeelmian Date: Mon, 9 Feb 2015 11:45:17 -0800 Subject: [PATCH] Added utility class, ForwardingServerListener, that forwards calls to underlying ServerCall.Listener. ------------- Created by MOE: http://code.google.com/p/moe-java MOE_MIGRATED_REVID=85910420 --- .../main/java/io/grpc/ServerInterceptors.java | 32 +++++++++++++++++++ 1 file changed, 32 insertions(+) diff --git a/core/src/main/java/io/grpc/ServerInterceptors.java b/core/src/main/java/io/grpc/ServerInterceptors.java index ad74fce7c7..13df6e4f5d 100644 --- a/core/src/main/java/io/grpc/ServerInterceptors.java +++ b/core/src/main/java/io/grpc/ServerInterceptors.java @@ -169,4 +169,36 @@ public class ServerInterceptors { return delegate.isCancelled(); } } + + /** + * Utility base class for decorating {@link ServerCall.Listener} instances. + */ + public static class ForwardingListener extends ServerCall.Listener { + + private final ServerCall.Listener delegate; + + public ForwardingListener(ServerCall.Listener delegate) { + this.delegate = delegate; + } + + @Override + public void onPayload(RespT payload) { + delegate.onPayload(payload); + } + + @Override + public void onHalfClose() { + delegate.onHalfClose(); + } + + @Override + public void onCancel() { + delegate.onCancel(); + } + + @Override + public void onComplete() { + delegate.onComplete(); + } + } }