File tree Expand file tree Collapse file tree
api/src/main/java/io/grpc
core/src/main/java/io/grpc/internal Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -279,7 +279,8 @@ public String getAuthority() {
279279 * Triggers a custom event to be processed by the listener.
280280 * The event will be delivered to {@link Listener#onEvent(Object)} on the call's executor.
281281 *
282- * <p>This method is thread-safe and can be called from any thread.
282+ * <p>This method is thread-safe and can be called from any thread. No events will be delivered
283+ * after the RPC is cancelled or completed.
283284 *
284285 * @param event the event to trigger.
285286 */
Original file line number Diff line number Diff line change @@ -178,9 +178,7 @@ public final void triggerEvent(final Object event) {
178178 transportState ().runOnTransportThread (new Runnable () {
179179 @ Override
180180 public void run () {
181- if (transportState ().listener != null ) {
182- transportState ().listener .triggerEvent (event );
183- }
181+ transportState ().triggerEvent (event );
184182 }
185183 });
186184 }
@@ -271,6 +269,13 @@ public void deframerClosed(boolean hasPartialMessage) {
271269
272270
273271
272+ public final void triggerEvent (Object event ) {
273+ if (listenerClosed ) {
274+ return ;
275+ }
276+ listener ().triggerEvent (event );
277+ }
278+
274279 @ Override
275280 protected ServerStreamListener listener () {
276281 return listener ;
You can’t perform that action at this time.
0 commit comments