cogrpc/tech.relaycorp.relaynet.cogrpc.client/CogRPCClient

CogRPCClient

open class CogRPCClient

Types

object Builder

CCARefusedException

class CCARefusedException : CogRPCClient.CogRPCException

CogRPCException

open class CogRPCException(throwable: Throwable? = null, message: String? = null) : Exception

object Companion

Functions

fun close()

fun collectCargo(cca: () -> InputStream): Flow<InputStream>

fun deliverCargo(cargoes: Iterable<CargoDeliveryRequest>): Flow<String>

Properties

channelBuilderProvider

val channelBuilderProvider: ChannelBuilderProvider<*>

val requireTls: Boolean