HttpStreamReader implements Subscriber<HttpObject> { @Override public void onSubscribe(Subscription subscription) { this.subscription = subscription; if (cancelled) { subscription.cancel(); return; } if (deferredInitialMessageRequest > 0) { request(deferredInitialMessageRequest); } } HttpStreamReader(DecompressorRegistry decompressorRegistry,
                            ArmeriaMessageDeframer deframer,
                            TransportStatusListener transportStatusListener); void request(int numMessages); @Override void onSubscribe(Subscription subscription); @Override void onNext(HttpObject obj); @Override void onError(Throwable cause); @Override void onComplete(); void cancel(); @VisibleForTesting
    final ArmeriaMessageDeframer deframer; }
@Test public void subscribe_noServerRequests() { reader.onSubscribe(subscription); verifyNoMoreInteractions(subscription); }