Implement triggerEvent for Binder transport.

Author: kannanjgithub

binder/src/main/java/io/grpc/binder/internal/Inbound.java

@@ -668,6 +668,16 @@ protected void deliverCloseAbnormal(Status status) {
       listener.closed(status);
     }
 
+    void triggerEvent(Object event) {
+      ServerStreamListener localListener;
+      synchronized (this) {
+        localListener = listener;
+      }
+      if (localListener != null) {
+        localListener.triggerEvent(event);
+      }
+    }
+
     @GuardedBy("this")
     void onCloseSent(Status status) {
       if (!isClosed()) {

binder/src/main/java/io/grpc/binder/internal/MultiMessageServerStream.java

@@ -177,7 +177,7 @@ public void setDecompressor(Decompressor decompressor) {
 
   @Override
   public void triggerEvent(Object event) {
-    // Ignore.
+    inbound.triggerEvent(event);
   }
 
   @Override

binder/src/main/java/io/grpc/binder/internal/SingleMessageServerStream.java

@@ -169,7 +169,7 @@ public void setDecompressor(Decompressor decompressor) {
 
   @Override
   public void triggerEvent(Object event) {
-    // Ignore.
+    inbound.triggerEvent(event);
   }
 
   @Override