trait TwitterStatusClient extends StreamingClient with Configurations with ActorContextExtractor
- Alphabetic
- By Inheritance
- TwitterStatusClient
- Configurations
- StreamingClient
- OAuthClient
- RequestBuilding
- TransformerPipelineSupport
- TokenProvider
- CommonClient
- ActorContextExtractor
- ActorSystemProvider
- ExecutionContextProvider
- JsonSupport
- Json4sSupport
- AnyRef
- Any
- Hide All
- Show All
- 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
-
lazy val
accessTokenKey: String
- Definition Classes
- Configurations
-
lazy val
accessTokenSecret: String
- Definition Classes
- Configurations
-
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
-
val
apiTwitterUrl: String
- Definition Classes
- Configurations
-
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
-
lazy val
consumerTokenKey: String
- Definition Classes
- Configurations
-
lazy val
consumerTokenSecret: String
- Definition Classes
- Configurations
-
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
filterStatuses(follow: Seq[Long] = Seq.empty, track: Seq[String] = Seq.empty, locations: Seq[Double] = Seq.empty, languages: Seq[Language] = Seq.empty, stall_warnings: Boolean = false)(f: PartialFunction[CommonStreamingMessage, Unit]): Future[TwitterStream]
Starts a streaming connection from Twitter's public API, filtered with the 'follow', 'track' and 'location' parameters.
Starts a streaming connection from Twitter's public API, filtered with the 'follow', 'track' and 'location' parameters. Although all of those three params are optional, at least one must be specified. The track, follow, and locations fields should be considered to be combined with an OR operator. The function returns a future of a
TwitterStream
that can be use to close or replace the stream when needed. If there are failures in establishing the initial connection, the Future returned will be completed with a failure. Since it's an asynchronous event stream, all the events will be parsed as entities of typeCommonStreamingMessage
and processed accordingly to the partial functionf
. All the messages that do not matchf
are automatically ignored. For more information see https://dev.twitter.com/streaming/reference/post/statuses/filter.- follow
: Empty by default. A comma separated list of user IDs, indicating the users to return statuses for in the stream. For more information https://dev.twitter.com/streaming/overview/request-parameters#follow
- track
: Empty by default. Keywords to track. Phrases of keywords are specified by a comma-separated list. For more information https://dev.twitter.com/streaming/overview/request-parameters#track
- locations
: Empty by default. Specifies a set of bounding boxes to track. For more information https://dev.twitter.com/streaming/overview/request-parameters#locations
- languages
: Empty by default. A comma separated list of 'BCP 47' language identifiers. For more information https://dev.twitter.com/streaming/overview/request-parameters#language
- stall_warnings
: Default to false. Specifies whether stall warnings (
WarningMessage
) should be delivered as part of the updates.
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
def
firehoseStatuses(count: Option[Int] = None, languages: Seq[Language] = Seq.empty, stall_warnings: Boolean = false)(f: PartialFunction[CommonStreamingMessage, Unit]): Future[TwitterStream]
Starts a streaming connection from Twitter's firehose API of all public statuses.
Starts a streaming connection from Twitter's firehose API of all public statuses. Few applications require this level of access. Creative use of a combination of other resources and various access levels can satisfy nearly every application use case. For more information see https://dev.twitter.com/streaming/reference/get/statuses/firehose. The function returns a future of a
TwitterStream
that can be use to close or replace the stream when needed. If there are failures in establishing the initial connection, the Future returned will be completed with a failure. Since it's an asynchronous event stream, all the events will be parsed as entities of typeCommonStreamingMessage
and processed accordingly to the partial functionf
. All the messages that do not matchf
are automatically ignored.- languages
: Empty by default. A comma separated list of 'BCP 47' language identifiers. For more information https://dev.twitter.com/streaming/overview/request-parameters#language
- stall_warnings
: Default to false. Specifies whether stall warnings (
WarningMessage
) should be delivered as part of the updates.
-
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
-
val
mediaTwitterUrl: String
- Definition Classes
- Configurations
-
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
- Definition Classes
- StreamingClient
-
def
processBody[T](response: HttpResponse, killSwitch: SharedKillSwitch)(f: PartialFunction[T, Unit])(implicit arg0: Manifest[T], request: HttpRequest): Unit
- Attributes
- protected
- Definition Classes
- StreamingClient
-
def
processStreamRequest[T <: StreamingMessage](request: HttpRequest, killSwitch: SharedKillSwitch)(f: PartialFunction[T, Unit])(implicit arg0: Manifest[T]): Future[SharedKillSwitch]
- Attributes
- protected
- Definition Classes
- StreamingClient
-
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
-
def
sampleStatuses(languages: Seq[Language] = Seq.empty, stall_warnings: Boolean = false)(f: PartialFunction[CommonStreamingMessage, Unit]): Future[TwitterStream]
Starts a streaming connection from Twitter's public API, which is a a small random sample of all public statuses.
Starts a streaming connection from Twitter's public API, which is a a small random sample of all public statuses. The Tweets returned by the default access level are the same, so if two different clients connect to this endpoint, they will see the same Tweets. The function returns a future of a
TwitterStream
that can be use to close or replace the stream when needed. If there are failures in establishing the initial connection, the Future returned will be completed with a failure. Since it's an asynchronous event stream, all the events will be parsed as entities of typeCommonStreamingMessage
and processed accordingly to the partial functionf
. All the messages that do not matchf
are automatically ignored. For more information see https://dev.twitter.com/streaming/reference/get/statuses/sample.- languages
: Empty by default. A comma separated list of 'BCP 47' language identifiers. For more information https://dev.twitter.com/streaming/overview/request-parameters#language
- stall_warnings
: Default to false. Specifies whether stall warnings (
WarningMessage
) should be delivered as part of the updates.
-
implicit
val
serialization: Serialization.type
- Definition Classes
- JsonSupport
-
val
siteStreamingTwitterUrl: String
- Definition Classes
- Configurations
-
val
statusStreamingTwitterUrl: String
- Definition Classes
- Configurations
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
val
twitterVersion: String
- Definition Classes
- Configurations
-
def
unmarshal[T](requestStartTime: Long, f: (HttpResponse) ⇒ Future[T])(implicit request: HttpRequest, response: HttpResponse): Future[T]
- Attributes
- protected
- Definition Classes
- CommonClient
-
val
userStreamingTwitterUrl: String
- Definition Classes
- Configurations
-
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
Deprecated Value Members
-
def
getStatusesFilter(follow: Seq[Long] = Seq.empty, track: Seq[String] = Seq.empty, locations: Seq[Double] = Seq.empty, languages: Seq[Language] = Seq.empty, stall_warnings: Boolean = false)(f: PartialFunction[CommonStreamingMessage, Unit]): Future[TwitterStream]
- Annotations
- @deprecated
- Deprecated
(Since version 2.2) use filterStatuses instead
-
def
getStatusesFirehose(count: Option[Int] = None, languages: Seq[Language] = Seq.empty, stall_warnings: Boolean = false)(f: PartialFunction[CommonStreamingMessage, Unit]): Future[TwitterStream]
- Annotations
- @deprecated
- Deprecated
(Since version 2.2) use firehoseStatuses instead
-
def
getStatusesSample(languages: Seq[Language] = Seq.empty, stall_warnings: Boolean = false)(f: PartialFunction[CommonStreamingMessage, Unit]): Future[TwitterStream]
- Annotations
- @deprecated
- Deprecated
(Since version 2.2) use sampleStatuses instead