Value Members

1.  final def !=(arg0: Any): Boolean

   Definition Classes

   Any

2.  final def ##: Int

   Definition Classes

   Any

3.  final def ==(arg0: Any): Boolean

   Definition Classes

   Any

4.  final def asInstanceOf[T0]: T0

   Definition Classes

   Any

5.  def getClass(): Class[_ <: AnyVal]

   Definition Classes

   AnyVal → Any

6.  def grpcBatchLookup[BatchRequest, BatchResponse, Response, Client <: AbstractFutureStub[Client]](channelSupplier: () => Channel, clientFactory: (Channel) => Client, batchSize: Int, batchRequestFn: (Seq[Request]) => BatchRequest, batchResponseFn: (BatchResponse) => Seq[(String, Response)], idExtractorFn: (Request) => String, maxPendingRequests: Int, cacheSupplier: CacheSupplier[String, Response] = new NoOpCacheSupplier[String, Response]())(f: (Client) => (BatchRequest) => ListenableFuture[BatchResponse])(implicit arg0: Coder[Response]): SCollection[(Request, Try[Response])]
7.  def grpcLookup[Response, Client <: AbstractFutureStub[Client]](channelSupplier: () => Channel, clientFactory: (Channel) => Client, maxPendingRequests: Int, cacheSupplier: CacheSupplier[Request, Response] = new NoOpCacheSupplier[Request, Response]())(f: (Client) => (Request) => ListenableFuture[Response])(implicit arg0: Coder[Response]): SCollection[(Request, Try[Response])]
8.  def grpcLookupStream[Response, Client <: AbstractStub[Client]](channelSupplier: () => Channel, clientFactory: (Channel) => Client, maxPendingRequests: Int, cacheSupplier: CacheSupplier[Request, Iterable[Response]] = new NoOpCacheSupplier[Request, JIterable[Response]]())(f: (Client) => (Request, StreamObserver[Response]) => Unit)(implicit arg0: Coder[Response]): SCollection[(Request, Try[Iterable[Response]])]
9.  final def isInstanceOf[T0]: Boolean

   Definition Classes

   Any

10.  def toString(): String

    Definition Classes

    Any