diff --git a/stub/src/main/java/com/google/net/stubby/stub/StreamObserver.java b/stub/src/main/java/com/google/net/stubby/stub/StreamObserver.java index 8b8a38a063..0a71b5483b 100644 --- a/stub/src/main/java/com/google/net/stubby/stub/StreamObserver.java +++ b/stub/src/main/java/com/google/net/stubby/stub/StreamObserver.java @@ -2,6 +2,9 @@ package com.google.net.stubby.stub; /** * Receives notifications from an observable stream of messages. + * + *

Implementations are expected to be thread-compatible. Separate StreamObservers do not need to + * be sychronized together; incoming and outgoing directions are independent. */ // TODO(user): Consider whether we need to interact with flow-control at this layer. E.g. // public ListenableFuture onValue(V value). Do we layer it in here or as an additional