Packages

trait StreamingClient extends OAuthClient

Source
StreamingClient.scala
Linear Supertypes
OAuthClient, RequestBuilding, TransformerPipelineSupport, TokenProvider, CommonClient, ActorContextExtractor, ActorSystemProvider, ExecutionContextProvider, JsonSupport, Json4sSupport, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. StreamingClient
  2. OAuthClient
  3. RequestBuilding
  4. TransformerPipelineSupport
  5. TokenProvider
  6. CommonClient
  7. ActorContextExtractor
  8. ActorSystemProvider
  9. ExecutionContextProvider
  10. JsonSupport
  11. Json4sSupport
  12. AnyRef
  13. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Type Members

  1. class OAuthRequestBuilder extends OAuthClient.RequestBuilder with BodyEncoder
    Definition Classes
    OAuthClient
  2. class RequestBuilder extends AnyRef
    Definition Classes
    RequestBuilding
  3. type RequestTransformer = (HttpRequest) ⇒ HttpRequest
    Definition Classes
    RequestBuilding
  4. implicit class WithTransformation[A] extends AnyRef
    Definition Classes
    TransformerPipelineSupport
  5. implicit class WithTransformerConcatenation[A, B] extends (A) ⇒ B
    Definition Classes
    TransformerPipelineSupport

Abstract Value Members

  1. abstract val accessToken: AccessToken
    Definition Classes
    TokenProvider
  2. abstract val consumerToken: ConsumerToken
    Definition Classes
    TokenProvider
  3. implicit abstract def system: ActorSystem
    Definition Classes
    ActorSystemProvider

Concrete Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. val Delete: OAuthRequestBuilder
    Definition Classes
    OAuthClient → RequestBuilding
  5. val Get: OAuthRequestBuilder
    Definition Classes
    OAuthClient → RequestBuilding
  6. val Head: OAuthRequestBuilder
    Definition Classes
    OAuthClient → RequestBuilding
  7. val Options: OAuthRequestBuilder
    Definition Classes
    OAuthClient → RequestBuilding
  8. val Patch: OAuthRequestBuilder
    Definition Classes
    OAuthClient → RequestBuilding
  9. val Post: OAuthRequestBuilder
    Definition Classes
    OAuthClient → RequestBuilding
  10. val Put: OAuthRequestBuilder
    Definition Classes
    OAuthClient → RequestBuilding
  11. def addCredentials(credentials: HttpCredentials): RequestTransformer
    Definition Classes
    RequestBuilding
  12. def addHeader(headerName: String, headerValue: String): RequestTransformer
    Definition Classes
    RequestBuilding
  13. def addHeader(header: HttpHeader): RequestTransformer
    Definition Classes
    RequestBuilding
  14. def addHeaders(first: HttpHeader, more: HttpHeader*): RequestTransformer
    Definition Classes
    RequestBuilding
  15. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  16. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  17. def connection(implicit request: HttpRequest): Flow[HttpRequest, HttpResponse, Future[OutgoingConnection]]
    Attributes
    protected
    Definition Classes
    CommonClient
  18. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  19. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  20. implicit val executionContext: ExecutionContext
    Definition Classes
    ActorContextExtractor → ExecutionContextProvider
  21. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  22. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
  23. def hashCode(): Int
    Definition Classes
    AnyRef → Any
  24. implicit def header2AddHeader(header: HttpHeader): RequestTransformer
    Definition Classes
    RequestBuilding
  25. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  26. implicit lazy val json4sFormats: Formats
    Definition Classes
    JsonSupport
  27. implicit def json4sMarshaller[A <: AnyRef](implicit serialization: Serialization, formats: Formats, shouldWritePretty: ShouldWritePretty): ToEntityMarshaller[A]
    Definition Classes
    Json4sSupport
  28. implicit def json4sUnmarshaller[A](implicit arg0: Manifest[A], serialization: Serialization, formats: Formats): FromEntityUnmarshaller[A]
    Definition Classes
    Json4sSupport
  29. implicit val log: Logger
    Definition Classes
    ActorContextExtractor
  30. def logRequest(logFun: (HttpRequest) ⇒ Unit): (HttpRequest) ⇒ HttpRequest
    Definition Classes
    RequestBuilding
  31. def logRequest(log: LoggingAdapter, level: LogLevel): (HttpRequest) ⇒ HttpRequest
    Definition Classes
    RequestBuilding
  32. def logRequest(implicit request: HttpRequest): HttpRequest
    Definition Classes
    CommonClient
  33. def logRequestResponse(requestStartTime: Long)(implicit request: HttpRequest): (HttpResponse) ⇒ HttpResponse
    Definition Classes
    CommonClient
  34. def logValue[T](logFun: (T) ⇒ Unit): (T) ⇒ T
    Definition Classes
    TransformerPipelineSupport
  35. def logValue[T](log: LoggingAdapter, level: LogLevel): (T) ⇒ T
    Definition Classes
    TransformerPipelineSupport
  36. def mapHeaders(f: (Seq[HttpHeader]) ⇒ Seq[HttpHeader]): RequestTransformer
    Definition Classes
    RequestBuilding
  37. implicit val materializer: ActorMaterializer
    Definition Classes
    ActorSystemProvider
  38. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  39. final def notify(): Unit
    Definition Classes
    AnyRef
  40. final def notifyAll(): Unit
    Definition Classes
    AnyRef
  41. lazy val oauthProvider: OAuth2Provider
    Attributes
    protected
    Definition Classes
    OAuthClient
  42. def parseFailedResponse(response: HttpResponse): Future[TwitterException]
    Attributes
    protected
    Definition Classes
    CommonClient
  43. def preProcessing(): Unit
    Attributes
    protected
  44. def processBody[T](response: HttpResponse, killSwitch: SharedKillSwitch)(f: PartialFunction[T, Unit])(implicit arg0: Manifest[T], request: HttpRequest): Unit
    Attributes
    protected
  45. def processStreamRequest[T <: StreamingMessage](request: HttpRequest, killSwitch: SharedKillSwitch)(f: PartialFunction[T, Unit])(implicit arg0: Manifest[T]): Future[SharedKillSwitch]
    Attributes
    protected
  46. def removeHeader(clazz: Class[_]): RequestTransformer
    Definition Classes
    RequestBuilding
  47. def removeHeader[T <: HttpHeader](implicit arg0: ClassTag[T]): RequestTransformer
    Definition Classes
    RequestBuilding
  48. def removeHeader(headerName: String): RequestTransformer
    Definition Classes
    RequestBuilding
  49. def removeHeaders(names: String*): RequestTransformer
    Definition Classes
    RequestBuilding
  50. implicit val serialization: Serialization.type
    Definition Classes
    JsonSupport
  51. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  52. def toString(): String
    Definition Classes
    AnyRef → Any
  53. def unmarshal[T](requestStartTime: Long, f: (HttpResponse) ⇒ Future[T])(implicit request: HttpRequest, response: HttpResponse): Future[T]
    Attributes
    protected
    Definition Classes
    CommonClient
  54. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  55. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  56. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  57. val withLogRequest: Boolean
    Definition Classes
    StreamingClientCommonClient
  58. val withLogRequestResponse: Boolean
    Definition Classes
    StreamingClientCommonClient
  59. def withOAuthHeader: (HttpRequest) ⇒ Future[HttpRequest]
    Definition Classes
    OAuthClient
  60. def withSimpleOAuthHeader: (HttpRequest) ⇒ Future[HttpRequest]
    Definition Classes
    OAuthClient

Inherited from OAuthClient

Inherited from RequestBuilding

Inherited from TransformerPipelineSupport

Inherited from TokenProvider

Inherited from CommonClient

Inherited from ActorContextExtractor

Inherited from ActorSystemProvider

Inherited from ExecutionContextProvider

Inherited from JsonSupport

Inherited from Json4sSupport

Inherited from AnyRef

Inherited from Any

Ungrouped