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

Change newtransport to use c.g.n.stubby.Status. 

c.g.n.stubby.Transport.Status isn't intended to be used (at least at
this point).
-------------
Created by MOE: http://code.google.com/p/moe-java
MOE_MIGRATED_REVID=69027874
This commit is contained in:
ejona 2014-06-11 16:24:43 -07:00 committed by Eric Anderson
parent 35cabd0b82
commit 5e01cea1ef
3 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
core/src/main/java/com/google/net/stubby/ChannelImpl.java
View File

@ -11,7 +11,6 @@ import com.google.net.stubby.newtransport.ClientStream;
import com.google.net.stubby.newtransport.ClientTransport;
import com.google.net.stubby.newtransport.ClientTransportFactory;
import com.google.net.stubby.newtransport.StreamListener;
import com.google.net.stubby.transport.Transport;
import java.io.InputStream;
import java.io.IOException;
@ -248,7 +247,7 @@ public final class ChannelImpl extends AbstractService implements Channel {
}
@Override
public void closed(final Transport.Status status) {
public void closed(final Status status) {
for (SettableFuture<Void> future : inProcessFutures) {
future.cancel(false);
}
@ -256,7 +255,7 @@ public final class ChannelImpl extends AbstractService implements Channel {
executor.execute(new Runnable() {
@Override
public void run() {
observer.onClose(new com.google.net.stubby.Status(status.getCode()));
observer.onClose(status);
}
});
}

2
core/src/main/java/com/google/net/stubby/newtransport/ServerStream.java
View File

@ -1,6 +1,6 @@
package com.google.net.stubby.newtransport;
import com.google.net.stubby.transport.Transport.Status;
import com.google.net.stubby.Status;
/**

2
core/src/main/java/com/google/net/stubby/newtransport/StreamListener.java
View File

@ -1,7 +1,7 @@
package com.google.net.stubby.newtransport;
import com.google.common.util.concurrent.ListenableFuture;
import com.google.net.stubby.transport.Transport.Status;
import com.google.net.stubby.Status;
import java.io.InputStream;