grpc
/
grpc-java
mirror of https://github.com/grpc/grpc-java.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Define threading requirements of StreamObserver 

-------------
Created by MOE: http://code.google.com/p/moe-java
MOE_MIGRATED_REVID=78404413
This commit is contained in:
ejona 2014-10-23 19:50:03 -07:00 committed by Eric Anderson
parent df9867def9
commit 96e6ed9c53
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
stub/src/main/java/com/google/net/stubby/stub/StreamObserver.java
View File

@ -2,6 +2,9 @@ package com.google.net.stubby.stub;
/** /**
* Receives notifications from an observable stream of messages. * Receives notifications from an observable stream of messages.
*
* <p>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. // TODO(user): Consider whether we need to interact with flow-control at this layer. E.g.
// public ListenableFuture<Void> onValue(V value). Do we layer it in here or as an additional // public ListenableFuture<Void> onValue(V value). Do we layer it in here or as an additional