File tree Expand file tree Collapse file tree
core/src/testFixtures/java/io/grpc/internal Expand file tree Collapse file tree Original file line number Diff line number Diff line change 2424import java .util .concurrent .LinkedBlockingQueue ;
2525import java .util .concurrent .TimeUnit ;
2626
27+ /**
28+ * A {@link ServerListener} that helps you write blocking unit tests.
29+ *
30+ * <p>TODO: Rename, since this is not actually a mock:
31+ * https://testing.googleblog.com/2013/07/testing-on-toilet-know-your-test-doubles.html
32+ */
2733public class MockServerListener implements ServerListener {
2834 private final BlockingQueue <MockServerTransportListener > listeners = new LinkedBlockingQueue <>();
2935 private final SettableFuture <?> shutdown = SettableFuture .create ();
Original file line number Diff line number Diff line change 2727import java .util .concurrent .LinkedBlockingQueue ;
2828import java .util .concurrent .TimeUnit ;
2929
30+ /**
31+ * A {@link ServerTransportListener} that helps you write blocking unit tests.
32+ *
33+ * <p>TODO: Rename, since this is not actually a mock:
34+ * https://testing.googleblog.com/2013/07/testing-on-toilet-know-your-test-doubles.html
35+ */
3036public class MockServerTransportListener implements ServerTransportListener {
3137 public final ServerTransport transport ;
32- public final BlockingQueue <StreamCreation > streams = new LinkedBlockingQueue <>();
38+ private final BlockingQueue <StreamCreation > streams = new LinkedBlockingQueue <>();
3339 private final SettableFuture <?> terminated = SettableFuture .create ();
3440
3541 public MockServerTransportListener (ServerTransport transport ) {
Original file line number Diff line number Diff line change 2828import java .util .concurrent .TimeUnit ;
2929
3030/**
31- * A {@link ServerStreamListener} that helps you write unit tests.
31+ * A {@link ServerStreamListener} that helps you write blocking unit tests.
3232 */
3333public class ServerStreamListenerBase implements ServerStreamListener {
3434 public final BlockingQueue <InputStream > messageQueue = new LinkedBlockingQueue <>();
You can’t perform that action at this time.
0 commit comments