open static fun <T : Any> create(observer: StreamObserver<T>): GrpcReadStream<T>
open static fun <T : Any> create(): GrpcReadStream<T>