wakingrufus

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 ->

wakingrufus

Keybase proof

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: