trait StreamingClient extends OAuthClient
- Source
- StreamingClient.scala
Linear Supertypes
OAuthClient, RequestBuilding, TransformerPipelineSupport, TokenProvider, CommonClient, ActorContextExtractor, ActorSystemProvider, ExecutionContextProvider, JsonSupport, Json4sSupport, AnyRef, Any
Known Subclasses
Ordering
- Alphabetic
- By Inheritance
Inherited
- StreamingClient
- OAuthClient
- RequestBuilding
- TransformerPipelineSupport
- TokenProvider
- CommonClient
- ActorContextExtractor
- ActorSystemProvider
- ExecutionContextProvider
- JsonSupport
- Json4sSupport
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Type Members
-
class
OAuthRequestBuilder extends OAuthClient.RequestBuilder with BodyEncoder
- Definition Classes
- OAuthClient
-
class
RequestBuilder extends AnyRef
- Definition Classes
- RequestBuilding
-
type
RequestTransformer = (HttpRequest) ⇒ HttpRequest
- Definition Classes
- RequestBuilding
-
implicit
class
WithTransformation[A] extends AnyRef
- Definition Classes
- TransformerPipelineSupport
-
implicit
class
WithTransformerConcatenation[A, B] extends (A) ⇒ B
- Definition Classes
- TransformerPipelineSupport
Abstract Value Members
-
abstract
val
accessToken: AccessToken
- Definition Classes
- TokenProvider
-
abstract
val
consumerToken: ConsumerToken
- Definition Classes
- TokenProvider
-
implicit abstract
def
system: ActorSystem
- Definition Classes
- ActorSystemProvider
Concrete Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
val
Delete: OAuthRequestBuilder
- Definition Classes
- OAuthClient → RequestBuilding
-
val
Get: OAuthRequestBuilder
- Definition Classes
- OAuthClient → RequestBuilding
-
val
Head: OAuthRequestBuilder
- Definition Classes
- OAuthClient → RequestBuilding
-
val
Options: OAuthRequestBuilder
- Definition Classes
- OAuthClient → RequestBuilding
-
val
Patch: OAuthRequestBuilder
- Definition Classes
- OAuthClient → RequestBuilding
-
val
Post: OAuthRequestBuilder
- Definition Classes
- OAuthClient → RequestBuilding
-
val
Put: OAuthRequestBuilder
- Definition Classes
- OAuthClient → RequestBuilding
-
def
addCredentials(credentials: HttpCredentials): RequestTransformer
- Definition Classes
- RequestBuilding
-
def
addHeader(headerName: String, headerValue: String): RequestTransformer
- Definition Classes
- RequestBuilding
-
def
addHeader(header: HttpHeader): RequestTransformer
- Definition Classes
- RequestBuilding
-
def
addHeaders(first: HttpHeader, more: HttpHeader*): RequestTransformer
- Definition Classes
- RequestBuilding
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
def
connection(implicit request: HttpRequest): Flow[HttpRequest, HttpResponse, Future[OutgoingConnection]]
- Attributes
- protected
- Definition Classes
- CommonClient
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
implicit
val
executionContext: ExecutionContext
- Definition Classes
- ActorContextExtractor → ExecutionContextProvider
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
-
implicit
def
header2AddHeader(header: HttpHeader): RequestTransformer
- Definition Classes
- RequestBuilding
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
implicit
lazy val
json4sFormats: Formats
- Definition Classes
- JsonSupport
-
implicit
def
json4sMarshaller[A <: AnyRef](implicit serialization: Serialization, formats: Formats, shouldWritePretty: ShouldWritePretty): ToEntityMarshaller[A]
- Definition Classes
- Json4sSupport
-
implicit
def
json4sUnmarshaller[A](implicit arg0: Manifest[A], serialization: Serialization, formats: Formats): FromEntityUnmarshaller[A]
- Definition Classes
- Json4sSupport
-
implicit
val
log: Logger
- Definition Classes
- ActorContextExtractor
-
def
logRequest(logFun: (HttpRequest) ⇒ Unit): (HttpRequest) ⇒ HttpRequest
- Definition Classes
- RequestBuilding
-
def
logRequest(log: LoggingAdapter, level: LogLevel): (HttpRequest) ⇒ HttpRequest
- Definition Classes
- RequestBuilding
-
def
logRequest(implicit request: HttpRequest): HttpRequest
- Definition Classes
- CommonClient
-
def
logRequestResponse(requestStartTime: Long)(implicit request: HttpRequest): (HttpResponse) ⇒ HttpResponse
- Definition Classes
- CommonClient
-
def
logValue[T](logFun: (T) ⇒ Unit): (T) ⇒ T
- Definition Classes
- TransformerPipelineSupport
-
def
logValue[T](log: LoggingAdapter, level: LogLevel): (T) ⇒ T
- Definition Classes
- TransformerPipelineSupport
-
def
mapHeaders(f: (Seq[HttpHeader]) ⇒ Seq[HttpHeader]): RequestTransformer
- Definition Classes
- RequestBuilding
-
implicit
val
materializer: ActorMaterializer
- Definition Classes
- ActorSystemProvider
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
-
lazy val
oauthProvider: OAuth2Provider
- Attributes
- protected
- Definition Classes
- OAuthClient
-
def
parseFailedResponse(response: HttpResponse): Future[TwitterException]
- Attributes
- protected
- Definition Classes
- CommonClient
-
def
preProcessing(): Unit
- Attributes
- protected
-
def
processBody[T](response: HttpResponse, killSwitch: SharedKillSwitch)(f: PartialFunction[T, Unit])(implicit arg0: Manifest[T], request: HttpRequest): Unit
- Attributes
- protected
-
def
processStreamRequest[T <: StreamingMessage](request: HttpRequest, killSwitch: SharedKillSwitch)(f: PartialFunction[T, Unit])(implicit arg0: Manifest[T]): Future[SharedKillSwitch]
- Attributes
- protected
-
def
removeHeader(clazz: Class[_]): RequestTransformer
- Definition Classes
- RequestBuilding
-
def
removeHeader[T <: HttpHeader](implicit arg0: ClassTag[T]): RequestTransformer
- Definition Classes
- RequestBuilding
-
def
removeHeader(headerName: String): RequestTransformer
- Definition Classes
- RequestBuilding
-
def
removeHeaders(names: String*): RequestTransformer
- Definition Classes
- RequestBuilding
-
implicit
val
serialization: Serialization.type
- Definition Classes
- JsonSupport
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
def
unmarshal[T](requestStartTime: Long, f: (HttpResponse) ⇒ Future[T])(implicit request: HttpRequest, response: HttpResponse): Future[T]
- Attributes
- protected
- Definition Classes
- CommonClient
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
val
withLogRequest: Boolean
- Definition Classes
- StreamingClient → CommonClient
-
val
withLogRequestResponse: Boolean
- Definition Classes
- StreamingClient → CommonClient
-
def
withOAuthHeader: (HttpRequest) ⇒ Future[HttpRequest]
- Definition Classes
- OAuthClient
-
def
withSimpleOAuthHeader: (HttpRequest) ⇒ Future[HttpRequest]
- Definition Classes
- OAuthClient
Inherited from OAuthClient
Value Members
-
val
Delete: OAuthRequestBuilder
- Definition Classes
- OAuthClient → RequestBuilding
-
val
Get: OAuthRequestBuilder
- Definition Classes
- OAuthClient → RequestBuilding
-
val
Head: OAuthRequestBuilder
- Definition Classes
- OAuthClient → RequestBuilding
-
val
Options: OAuthRequestBuilder
- Definition Classes
- OAuthClient → RequestBuilding
-
val
Patch: OAuthRequestBuilder
- Definition Classes
- OAuthClient → RequestBuilding
-
val
Post: OAuthRequestBuilder
- Definition Classes
- OAuthClient → RequestBuilding
-
val
Put: OAuthRequestBuilder
- Definition Classes
- OAuthClient → RequestBuilding
-
lazy val
oauthProvider: OAuth2Provider
- Attributes
- protected
- Definition Classes
- OAuthClient
-
def
withOAuthHeader: (HttpRequest) ⇒ Future[HttpRequest]
- Definition Classes
- OAuthClient
-
def
withSimpleOAuthHeader: (HttpRequest) ⇒ Future[HttpRequest]
- Definition Classes
- OAuthClient
Inherited from RequestBuilding
Value Members
-
def
addCredentials(credentials: HttpCredentials): RequestTransformer
- Definition Classes
- RequestBuilding
-
def
addHeader(headerName: String, headerValue: String): RequestTransformer
- Definition Classes
- RequestBuilding
-
def
addHeader(header: HttpHeader): RequestTransformer
- Definition Classes
- RequestBuilding
-
def
addHeaders(first: HttpHeader, more: HttpHeader*): RequestTransformer
- Definition Classes
- RequestBuilding
-
implicit
def
header2AddHeader(header: HttpHeader): RequestTransformer
- Definition Classes
- RequestBuilding
-
def
logRequest(logFun: (HttpRequest) ⇒ Unit): (HttpRequest) ⇒ HttpRequest
- Definition Classes
- RequestBuilding
-
def
logRequest(log: LoggingAdapter, level: LogLevel): (HttpRequest) ⇒ HttpRequest
- Definition Classes
- RequestBuilding
-
def
mapHeaders(f: (Seq[HttpHeader]) ⇒ Seq[HttpHeader]): RequestTransformer
- Definition Classes
- RequestBuilding
-
def
removeHeader(clazz: Class[_]): RequestTransformer
- Definition Classes
- RequestBuilding
-
def
removeHeader[T <: HttpHeader](implicit arg0: ClassTag[T]): RequestTransformer
- Definition Classes
- RequestBuilding
-
def
removeHeader(headerName: String): RequestTransformer
- Definition Classes
- RequestBuilding
-
def
removeHeaders(names: String*): RequestTransformer
- Definition Classes
- RequestBuilding
Inherited from TransformerPipelineSupport
Value Members
-
def
logValue[T](logFun: (T) ⇒ Unit): (T) ⇒ T
- Definition Classes
- TransformerPipelineSupport
-
def
logValue[T](log: LoggingAdapter, level: LogLevel): (T) ⇒ T
- Definition Classes
- TransformerPipelineSupport
Inherited from TokenProvider
Value Members
-
abstract
val
accessToken: AccessToken
- Definition Classes
- TokenProvider
-
abstract
val
consumerToken: ConsumerToken
- Definition Classes
- TokenProvider
Inherited from CommonClient
Value Members
-
def
connection(implicit request: HttpRequest): Flow[HttpRequest, HttpResponse, Future[OutgoingConnection]]
- Attributes
- protected
- Definition Classes
- CommonClient
-
def
logRequest(implicit request: HttpRequest): HttpRequest
- Definition Classes
- CommonClient
-
def
logRequestResponse(requestStartTime: Long)(implicit request: HttpRequest): (HttpResponse) ⇒ HttpResponse
- Definition Classes
- CommonClient
-
def
parseFailedResponse(response: HttpResponse): Future[TwitterException]
- Attributes
- protected
- Definition Classes
- CommonClient
-
def
unmarshal[T](requestStartTime: Long, f: (HttpResponse) ⇒ Future[T])(implicit request: HttpRequest, response: HttpResponse): Future[T]
- Attributes
- protected
- Definition Classes
- CommonClient
Inherited from ActorContextExtractor
Value Members
-
implicit
val
executionContext: ExecutionContext
- Definition Classes
- ActorContextExtractor → ExecutionContextProvider
-
implicit
val
log: Logger
- Definition Classes
- ActorContextExtractor
Inherited from ActorSystemProvider
Value Members
-
implicit abstract
def
system: ActorSystem
- Definition Classes
- ActorSystemProvider
-
implicit
val
materializer: ActorMaterializer
- Definition Classes
- ActorSystemProvider
Inherited from JsonSupport
Value Members
-
implicit
lazy val
json4sFormats: Formats
- Definition Classes
- JsonSupport
-
implicit
val
serialization: Serialization.type
- Definition Classes
- JsonSupport
Inherited from Json4sSupport
Value Members
-
implicit
def
json4sMarshaller[A <: AnyRef](implicit serialization: Serialization, formats: Formats, shouldWritePretty: ShouldWritePretty): ToEntityMarshaller[A]
- Definition Classes
- Json4sSupport
-
implicit
def
json4sUnmarshaller[A](implicit arg0: Manifest[A], serialization: Serialization, formats: Formats): FromEntityUnmarshaller[A]
- Definition Classes
- Json4sSupport
Inherited from AnyRef
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
Ungrouped
-
class
OAuthRequestBuilder extends OAuthClient.RequestBuilder with BodyEncoder
- Definition Classes
- OAuthClient
-
class
RequestBuilder extends AnyRef
- Definition Classes
- RequestBuilding
-
type
RequestTransformer = (HttpRequest) ⇒ HttpRequest
- Definition Classes
- RequestBuilding
-
implicit
class
WithTransformation[A] extends AnyRef
- Definition Classes
- TransformerPipelineSupport
-
implicit
class
WithTransformerConcatenation[A, B] extends (A) ⇒ B
- Definition Classes
- TransformerPipelineSupport
-
abstract
val
accessToken: AccessToken
- Definition Classes
- TokenProvider
-
abstract
val
consumerToken: ConsumerToken
- Definition Classes
- TokenProvider
-
implicit abstract
def
system: ActorSystem
- Definition Classes
- ActorSystemProvider
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
val
Delete: OAuthRequestBuilder
- Definition Classes
- OAuthClient → RequestBuilding
-
val
Get: OAuthRequestBuilder
- Definition Classes
- OAuthClient → RequestBuilding
-
val
Head: OAuthRequestBuilder
- Definition Classes
- OAuthClient → RequestBuilding
-
val
Options: OAuthRequestBuilder
- Definition Classes
- OAuthClient → RequestBuilding
-
val
Patch: OAuthRequestBuilder
- Definition Classes
- OAuthClient → RequestBuilding
-
val
Post: OAuthRequestBuilder
- Definition Classes
- OAuthClient → RequestBuilding
-
val
Put: OAuthRequestBuilder
- Definition Classes
- OAuthClient → RequestBuilding
-
def
addCredentials(credentials: HttpCredentials): RequestTransformer
- Definition Classes
- RequestBuilding
-
def
addHeader(headerName: String, headerValue: String): RequestTransformer
- Definition Classes
- RequestBuilding
-
def
addHeader(header: HttpHeader): RequestTransformer
- Definition Classes
- RequestBuilding
-
def
addHeaders(first: HttpHeader, more: HttpHeader*): RequestTransformer
- Definition Classes
- RequestBuilding
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
def
connection(implicit request: HttpRequest): Flow[HttpRequest, HttpResponse, Future[OutgoingConnection]]
- Attributes
- protected
- Definition Classes
- CommonClient
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
implicit
val
executionContext: ExecutionContext
- Definition Classes
- ActorContextExtractor → ExecutionContextProvider
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
-
implicit
def
header2AddHeader(header: HttpHeader): RequestTransformer
- Definition Classes
- RequestBuilding
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
implicit
lazy val
json4sFormats: Formats
- Definition Classes
- JsonSupport
-
implicit
def
json4sMarshaller[A <: AnyRef](implicit serialization: Serialization, formats: Formats, shouldWritePretty: ShouldWritePretty): ToEntityMarshaller[A]
- Definition Classes
- Json4sSupport
-
implicit
def
json4sUnmarshaller[A](implicit arg0: Manifest[A], serialization: Serialization, formats: Formats): FromEntityUnmarshaller[A]
- Definition Classes
- Json4sSupport
-
implicit
val
log: Logger
- Definition Classes
- ActorContextExtractor
-
def
logRequest(logFun: (HttpRequest) ⇒ Unit): (HttpRequest) ⇒ HttpRequest
- Definition Classes
- RequestBuilding
-
def
logRequest(log: LoggingAdapter, level: LogLevel): (HttpRequest) ⇒ HttpRequest
- Definition Classes
- RequestBuilding
-
def
logRequest(implicit request: HttpRequest): HttpRequest
- Definition Classes
- CommonClient
-
def
logRequestResponse(requestStartTime: Long)(implicit request: HttpRequest): (HttpResponse) ⇒ HttpResponse
- Definition Classes
- CommonClient
-
def
logValue[T](logFun: (T) ⇒ Unit): (T) ⇒ T
- Definition Classes
- TransformerPipelineSupport
-
def
logValue[T](log: LoggingAdapter, level: LogLevel): (T) ⇒ T
- Definition Classes
- TransformerPipelineSupport
-
def
mapHeaders(f: (Seq[HttpHeader]) ⇒ Seq[HttpHeader]): RequestTransformer
- Definition Classes
- RequestBuilding
-
implicit
val
materializer: ActorMaterializer
- Definition Classes
- ActorSystemProvider
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
-
lazy val
oauthProvider: OAuth2Provider
- Attributes
- protected
- Definition Classes
- OAuthClient
-
def
parseFailedResponse(response: HttpResponse): Future[TwitterException]
- Attributes
- protected
- Definition Classes
- CommonClient
-
def
preProcessing(): Unit
- Attributes
- protected
-
def
processBody[T](response: HttpResponse, killSwitch: SharedKillSwitch)(f: PartialFunction[T, Unit])(implicit arg0: Manifest[T], request: HttpRequest): Unit
- Attributes
- protected
-
def
processStreamRequest[T <: StreamingMessage](request: HttpRequest, killSwitch: SharedKillSwitch)(f: PartialFunction[T, Unit])(implicit arg0: Manifest[T]): Future[SharedKillSwitch]
- Attributes
- protected
-
def
removeHeader(clazz: Class[_]): RequestTransformer
- Definition Classes
- RequestBuilding
-
def
removeHeader[T <: HttpHeader](implicit arg0: ClassTag[T]): RequestTransformer
- Definition Classes
- RequestBuilding
-
def
removeHeader(headerName: String): RequestTransformer
- Definition Classes
- RequestBuilding
-
def
removeHeaders(names: String*): RequestTransformer
- Definition Classes
- RequestBuilding
-
implicit
val
serialization: Serialization.type
- Definition Classes
- JsonSupport
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
def
unmarshal[T](requestStartTime: Long, f: (HttpResponse) ⇒ Future[T])(implicit request: HttpRequest, response: HttpResponse): Future[T]
- Attributes
- protected
- Definition Classes
- CommonClient
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
val
withLogRequest: Boolean
- Definition Classes
- StreamingClient → CommonClient
-
val
withLogRequestResponse: Boolean
- Definition Classes
- StreamingClient → CommonClient
-
def
withOAuthHeader: (HttpRequest) ⇒ Future[HttpRequest]
- Definition Classes
- OAuthClient
-
def
withSimpleOAuthHeader: (HttpRequest) ⇒ Future[HttpRequest]
- Definition Classes
- OAuthClient