I hereby claim:
- I am wakingrufus on github.
- I am wakingrufus (https://keybase.io/wakingrufus) on keybase.
- I have a public key ASA4zDc-o9OdFSStwmxKtdWyAF4IDQNPRr4RrARPB2Mrdgo
To claim this, I am signing this object:
I hereby claim:
To claim this, I am signing this object:
import com.google.protobuf.GeneratedMessageV3 | |
import io.grpc.Channel | |
import io.grpc.ManagedChannel | |
import io.grpc.ManagedChannelBuilder | |
import io.grpc.stub.AbstractStub | |
import io.grpc.stub.StreamObserver | |
import java.util.concurrent.CompletableFuture | |
fun <S : AbstractStub<S>, I, R : GeneratedMessageV3> grpcCall(stub: S, call: S.(I, StreamObserver<R>) -> Unit): (I) -> CompletableFuture<R> { | |
return { input -> |