protected void assertClientStreamingCallSuccess(final TestServiceStub serviceStub) {
        final StreamRecorder<Empty> responseRecorder = StreamRecorder.create();
        final StreamObserver<SomeType> requestObserver = serviceStub.secureDrain(responseRecorder);
        sendAndComplete(requestObserver, "1.2.3");
        assertFutureFirstEquals(EMPTY, responseRecorder, 15, TimeUnit.SECONDS);
    }
Tests with client streaming call.

@return The tests.
tests/src/test/java/net/devh/boot/grpc/test/security/AbstractSecurityTest.java