class StreamingTwitterClient[F[_], P <: Streams[P]] extends TwitterClient[[_]F[_]]
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- StreamingTwitterClient
- TwitterClient
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new StreamingTwitterClient(consumerKey: ConsumerKey, bearerToken: String)(implicit backend: SttpBackend[F, P], s: P)
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 addOAuthHeader(request: Request[Either[String, String], Any], formParams: Map[String, String] = Map.empty, credentials: Option[OAuthToken] = None, callbackUrl: Option[String] = None): RequestT[Identity, Either[String, String], Any]
- Attributes
- protected
- Definition Classes
- TwitterClient
- def addStreamRule(value: String, tag: Option[String], dryRun: Boolean = false): F[StreamRulesResponse]
- Definition Classes
- TwitterClient
- def asFormData: ResponseAs[Either[TwitterHttpException with Product, Map[String, String]], Any]
- Attributes
- protected
- Definition Classes
- TwitterClient
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def asJsonV1[T](implicit arg0: Reads[T], arg1: IsOption[T]): ResponseAs[Either[TwitterException with Product, T], Any]
- Attributes
- protected
- Definition Classes
- TwitterClient
- def asJsonV2[T](implicit arg0: Reads[T], arg1: IsOption[T]): ResponseAs[Either[TwitterException with Product, T], Any]
- Attributes
- protected
- Definition Classes
- TwitterClient
- def asStreamV2: ResponseAs[Either[TwitterHttpException with Product, P.BinaryStream], P]
- Attributes
- protected
- val baseUrl: String
- Attributes
- protected
- Definition Classes
- TwitterClient
- def bearerGet[T](url: Uri)(implicit arg0: Reads[T]): F[T]
- Attributes
- protected
- Definition Classes
- TwitterClient
- def bearerPost[T](url: Uri, payload: JsObject)(implicit arg0: Reads[T]): F[T]
- Attributes
- protected
- Definition Classes
- TwitterClient
- def bearerStream(url: Uri): F[P.BinaryStream]
- Attributes
- protected
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- def foldPages[T <: Page, A](call: (Option[String]) => F[T])(zero: A)(f: (A, T) => A): F[A]
- Definition Classes
- TwitterClient
- def getAccessToken(token: OAuthToken, verifier: String): F[OAuthToken]
- Definition Classes
- TwitterClient
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def getRecentTweets(query: String, expansions: Set[TweetExpansion] = Set.empty, tweetFields: Set[TweetField] = Set.empty, mediaFields: Set[MediaField] = Set.empty, placeFields: Set[PlaceField] = Set.empty, pollFields: Set[PollField] = Set.empty, userFields: Set[UserField] = Set.empty, sinceId: Option[BigInt] = None, untilId: Option[BigInt] = None, startTime: Option[Instant] = None, endTime: Option[Instant] = None, maxResults: Int = 10, nextToken: Option[String] = None): F[TweetPage]
- Definition Classes
- TwitterClient
- def getStreamRules(ids: Set[BigInt] = Set.empty): F[Seq[StreamRule]]
- Definition Classes
- TwitterClient
- def getUserById(id: BigInt, expansions: Set[UserExpansion] = Set.empty, userFields: Set[UserField] = Set.empty, tweetFields: Set[TweetField] = Set.empty): F[UserLookup]
- Definition Classes
- TwitterClient
- def getUserByUsername(username: String, expansions: Set[UserExpansion] = Set.empty, userFields: Set[UserField] = Set.empty, tweetFields: Set[TweetField] = Set.empty): F[UserLookup]
- Definition Classes
- TwitterClient
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- val logger: Slf4jLogger[[_]F[_]]
- Attributes
- protected
- Definition Classes
- TwitterClient
- val loggingBackend: SttpBackend[[_]F[_], Any]
- Attributes
- protected
- Definition Classes
- TwitterClient
- implicit val monad: MonadError[[_]F[_]]
- Attributes
- protected
- Definition Classes
- TwitterClient
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def oauthGet[T](url: Uri, credentials: OAuthToken)(implicit arg0: Reads[T]): F[T]
- Attributes
- protected
- Definition Classes
- TwitterClient
- def oauthPost[T](url: Uri, payload: JsObject, credentials: OAuthToken)(implicit arg0: Reads[T]): F[T]
- Attributes
- protected
- Definition Classes
- TwitterClient
- def oauthPostForm(url: Uri, formData: Map[String, String] = Map.empty, credentials: Option[OAuthToken] = None, callbackUrl: Option[String] = None): F[Map[String, String]]
- Attributes
- protected
- Definition Classes
- TwitterClient
- def parseStreamElement(body: String): TweetElement
- def removeStreamRules(ids: Set[BigInt], dryRun: Boolean = false): F[StreamRulesResponse]
- Definition Classes
- TwitterClient
- def requestToken(callbackUrl: String, accessType: Option[AccessType.Value] = None): F[OAuthToken]
- Definition Classes
- TwitterClient
- implicit val s: P
- def send[T](request: RequestT[Identity, Either[TwitterException, T], Any]): F[T]
- Attributes
- protected
- Definition Classes
- TwitterClient
- def sendAndParseFormData(request: RequestT[Identity, Either[String, String], Any]): F[Map[String, String]]
- Attributes
- protected
- Definition Classes
- TwitterClient
- def sendAndParseJsonV1[T](request: RequestT[Identity, Either[String, String], Any])(implicit arg0: Reads[T]): F[T]
- Attributes
- protected
- Definition Classes
- TwitterClient
- def sendAndParseJsonV2[T](request: RequestT[Identity, Either[String, String], Any])(implicit arg0: Reads[T]): F[T]
- Attributes
- protected
- Definition Classes
- TwitterClient
- def sendDirectMessage(credentials: OAuthToken, recipientId: BigInt, text: String): F[Unit]
- Definition Classes
- TwitterClient
- val streamLoggingBackend: SttpBackend[[_]F[_], P]
- Attributes
- protected
- def streamTweets(expansions: Set[TweetExpansion] = Set.empty, tweetFields: Set[TweetField] = Set(TweetField.Id, TweetField.Text), mediaFields: Set[MediaField] = Set.empty, placeFields: Set[PlaceField] = Set.empty, pollFields: Set[PollField] = Set.empty, userFields: Set[UserField] = Set.empty): F[P.BinaryStream]
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- def uaRequest: RequestT[Empty, Either[String, String], Any]
- Attributes
- protected
- Definition Classes
- TwitterClient
- val v1BaseUrl: String
- Attributes
- protected
- Definition Classes
- TwitterClient
- val v2BaseUrl: String
- Attributes
- protected
- Definition Classes
- TwitterClient
- def verifyCredentials(credentials: OAuthToken, includeEmail: Boolean = false): F[ShortUserV1]
- Definition Classes
- TwitterClient
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()