o

akka.grpc.internal

AkkaHttpClientUtils

object AkkaHttpClientUtils

INTERNAL API

Annotations
@InternalApi()
Source
AkkaHttpClientUtils.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. AkkaHttpClientUtils
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Type Members

  1. case class ResponsePromise(promise: Promise[HttpResponse]) extends RequestResponseAssociation with Product with Serializable

Value Members

  1. def createChannel(settings: GrpcClientSettings, log: LoggingAdapter)(implicit sys: ClassicActorSystemProvider): InternalChannel

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  2. def responseToSource[O](requestUri: Uri, response: Future[HttpResponse], deserializer: ProtobufSerializer[O], streamingResponse: Boolean)(implicit ec: ExecutionContext, mat: Materializer): Source[O, Future[GrpcResponseMetadata]]

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  3. object ResponsePromise extends Serializable