Packages

trait TwitterStatusClient extends StreamingClient with Configurations with ActorContextExtractor

Source
TwitterStatusClient.scala
Linear Supertypes
Configurations, StreamingClient, OAuthClient, RequestBuilding, TransformerPipelineSupport, TokenProvider, CommonClient, ActorContextExtractor, ActorSystemProvider, ExecutionContextProvider, JsonSupport, Json4sSupport, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. TwitterStatusClient
  2. Configurations
  3. StreamingClient
  4. OAuthClient
  5. RequestBuilding
  6. TransformerPipelineSupport
  7. TokenProvider
  8. CommonClient
  9. ActorContextExtractor
  10. ActorSystemProvider
  11. ExecutionContextProvider
  12. JsonSupport
  13. Json4sSupport
  14. AnyRef
  15. 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. lazy val accessTokenKey: String
    Definition Classes
    Configurations
  12. lazy val accessTokenSecret: String
    Definition Classes
    Configurations
  13. def addCredentials(credentials: HttpCredentials): RequestTransformer
    Definition Classes
    RequestBuilding
  14. def addHeader(headerName: String, headerValue: String): RequestTransformer
    Definition Classes
    RequestBuilding
  15. def addHeader(header: HttpHeader): RequestTransformer
    Definition Classes
    RequestBuilding
  16. def addHeaders(first: HttpHeader, more: HttpHeader*): RequestTransformer
    Definition Classes
    RequestBuilding
  17. val apiTwitterUrl: String
    Definition Classes
    Configurations
  18. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  19. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  20. def connection(implicit request: HttpRequest): Flow[HttpRequest, HttpResponse, Future[OutgoingConnection]]
    Attributes
    protected
    Definition Classes
    CommonClient
  21. lazy val consumerTokenKey: String
    Definition Classes
    Configurations
  22. lazy val consumerTokenSecret: String
    Definition Classes
    Configurations
  23. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  24. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  25. implicit val executionContext: ExecutionContext
    Definition Classes
    ActorContextExtractor → ExecutionContextProvider
  26. 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 type CommonStreamingMessage and processed accordingly to the partial function f. All the messages that do not match f 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.

  27. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  28. 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 type CommonStreamingMessage and processed accordingly to the partial function f. All the messages that do not match f 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.

  29. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
  30. def hashCode(): Int
    Definition Classes
    AnyRef → Any
  31. implicit def header2AddHeader(header: HttpHeader): RequestTransformer
    Definition Classes
    RequestBuilding
  32. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  33. implicit lazy val json4sFormats: Formats
    Definition Classes
    JsonSupport
  34. implicit def json4sMarshaller[A <: AnyRef](implicit serialization: Serialization, formats: Formats, shouldWritePretty: ShouldWritePretty): ToEntityMarshaller[A]
    Definition Classes
    Json4sSupport
  35. implicit def json4sUnmarshaller[A](implicit arg0: Manifest[A], serialization: Serialization, formats: Formats): FromEntityUnmarshaller[A]
    Definition Classes
    Json4sSupport
  36. implicit val log: Logger
    Definition Classes
    ActorContextExtractor
  37. def logRequest(logFun: (HttpRequest) ⇒ Unit): (HttpRequest) ⇒ HttpRequest
    Definition Classes
    RequestBuilding
  38. def logRequest(log: LoggingAdapter, level: LogLevel): (HttpRequest) ⇒ HttpRequest
    Definition Classes
    RequestBuilding
  39. def logRequest(implicit request: HttpRequest): HttpRequest
    Definition Classes
    CommonClient
  40. def logRequestResponse(requestStartTime: Long)(implicit request: HttpRequest): (HttpResponse) ⇒ HttpResponse
    Definition Classes
    CommonClient
  41. def logValue[T](logFun: (T) ⇒ Unit): (T) ⇒ T
    Definition Classes
    TransformerPipelineSupport
  42. def logValue[T](log: LoggingAdapter, level: LogLevel): (T) ⇒ T
    Definition Classes
    TransformerPipelineSupport
  43. def mapHeaders(f: (Seq[HttpHeader]) ⇒ Seq[HttpHeader]): RequestTransformer
    Definition Classes
    RequestBuilding
  44. implicit val materializer: ActorMaterializer
    Definition Classes
    ActorSystemProvider
  45. val mediaTwitterUrl: String
    Definition Classes
    Configurations
  46. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  47. final def notify(): Unit
    Definition Classes
    AnyRef
  48. final def notifyAll(): Unit
    Definition Classes
    AnyRef
  49. lazy val oauthProvider: OAuth2Provider
    Attributes
    protected
    Definition Classes
    OAuthClient
  50. def parseFailedResponse(response: HttpResponse): Future[TwitterException]
    Attributes
    protected
    Definition Classes
    CommonClient
  51. def preProcessing(): Unit
    Attributes
    protected
    Definition Classes
    StreamingClient
  52. def processBody[T](response: HttpResponse, killSwitch: SharedKillSwitch)(f: PartialFunction[T, Unit])(implicit arg0: Manifest[T], request: HttpRequest): Unit
    Attributes
    protected
    Definition Classes
    StreamingClient
  53. def processStreamRequest[T <: StreamingMessage](request: HttpRequest, killSwitch: SharedKillSwitch)(f: PartialFunction[T, Unit])(implicit arg0: Manifest[T]): Future[SharedKillSwitch]
    Attributes
    protected
    Definition Classes
    StreamingClient
  54. def removeHeader(clazz: Class[_]): RequestTransformer
    Definition Classes
    RequestBuilding
  55. def removeHeader[T <: HttpHeader](implicit arg0: ClassTag[T]): RequestTransformer
    Definition Classes
    RequestBuilding
  56. def removeHeader(headerName: String): RequestTransformer
    Definition Classes
    RequestBuilding
  57. def removeHeaders(names: String*): RequestTransformer
    Definition Classes
    RequestBuilding
  58. 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 type CommonStreamingMessage and processed accordingly to the partial function f. All the messages that do not match f 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.

  59. implicit val serialization: Serialization.type
    Definition Classes
    JsonSupport
  60. val siteStreamingTwitterUrl: String
    Definition Classes
    Configurations
  61. val statusStreamingTwitterUrl: String
    Definition Classes
    Configurations
  62. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  63. def toString(): String
    Definition Classes
    AnyRef → Any
  64. val twitterVersion: String
    Definition Classes
    Configurations
  65. def unmarshal[T](requestStartTime: Long, f: (HttpResponse) ⇒ Future[T])(implicit request: HttpRequest, response: HttpResponse): Future[T]
    Attributes
    protected
    Definition Classes
    CommonClient
  66. val userStreamingTwitterUrl: String
    Definition Classes
    Configurations
  67. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  68. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  69. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  70. val withLogRequest: Boolean
    Definition Classes
    StreamingClientCommonClient
  71. val withLogRequestResponse: Boolean
    Definition Classes
    StreamingClientCommonClient
  72. def withOAuthHeader: (HttpRequest) ⇒ Future[HttpRequest]
    Definition Classes
    OAuthClient
  73. def withSimpleOAuthHeader: (HttpRequest) ⇒ Future[HttpRequest]
    Definition Classes
    OAuthClient

Deprecated Value Members

  1. 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

  2. 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

  3. 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

Inherited from Configurations

Inherited from StreamingClient

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