@Test public void sendSuccessfulMessageTest() throws Exception { writer.setServiceStatus(Status.OK); sendSuccessfulMessage(); stub.close(); }
public void close() { writer.onCompleted(); }
AltsHandshakerStub { public void close() { writer.onCompleted(); } }
AltsHandshakerStub { public void close() { writer.onCompleted(); } AltsHandshakerStub(HandshakerServiceStub serviceStub); @VisibleForTesting  AltsHandshakerStub(); @VisibleForTesting  AltsHandshakerStub(StreamObserver<HandshakerReq> writer); }
AltsHandshakerStub { public void close() { writer.onCompleted(); } AltsHandshakerStub(HandshakerServiceStub serviceStub); @VisibleForTesting  AltsHandshakerStub(); @VisibleForTesting  AltsHandshakerStub(StreamObserver<HandshakerReq> writer); HandshakerResp send(HandshakerReq req); void close(); }
AltsHandshakerStub { public void close() { writer.onCompleted(); } AltsHandshakerStub(HandshakerServiceStub serviceStub); @VisibleForTesting  AltsHandshakerStub(); @VisibleForTesting  AltsHandshakerStub(StreamObserver<HandshakerReq> writer); HandshakerResp send(HandshakerReq req); void close();  }