trait Http1Stage[F[_]] extends AnyRef
Utility bits for dealing with the HTTP 1.x protocol
- Self Type
- Http1Stage[F] with TailStage[ByteBuffer]
- Source
- Http1Stage.scala
- Alphabetic
- By Inheritance
- Http1Stage
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- All
Abstract Value Members
-
implicit abstract
def
F: Effect[F]
- Attributes
- protected
-
abstract
def
contentComplete(): Boolean
- Attributes
- protected
-
abstract
def
doParseContent(buffer: ByteBuffer): Option[ByteBuffer]
- Attributes
- protected
-
implicit abstract
def
executionContext: ExecutionContext
ExecutionContext to be used for all Future continuations WARNING: The ExecutionContext should trampoline or risk possibly unhandled stack overflows
ExecutionContext to be used for all Future continuations WARNING: The ExecutionContext should trampoline or risk possibly unhandled stack overflows
- Attributes
- protected
Concrete Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
def
+(other: String): String
- Implicit
- This member is added by an implicit conversion from Http1Stage[F] to any2stringadd[Http1Stage[F]] performed by method any2stringadd in scala.Predef.
- Definition Classes
- any2stringadd
-
def
->[B](y: B): (Http1Stage[F], B)
- Implicit
- This member is added by an implicit conversion from Http1Stage[F] to ArrowAssoc[Http1Stage[F]] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
- Annotations
- @inline()
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
final
def
checkCloseConnection(conn: Connection, rr: StringWriter): Boolean
Check Connection header and add applicable headers to response
Check Connection header and add applicable headers to response
- Attributes
- protected
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
final
def
collectBodyFromParser(buffer: ByteBuffer, eofCondition: () ⇒ Either[Throwable, Option[Chunk[Byte]]]): (EntityBody[F], () ⇒ Future[ByteBuffer])
Makes a EntityBody and a function used to drain the line if terminated early.
Makes a EntityBody and a function used to drain the line if terminated early.
- buffer
starting
ByteBuffer
to use in parsing.- eofCondition
If the other end hangs up, this is the condition used in the stream for termination. The desired result will differ between Client and Server as the former can interpret and
Command.EOF
as the end of the body while a server cannot.
- Attributes
- protected
-
final
def
drainBody(buffer: ByteBuffer): Future[ByteBuffer]
Cleans out any remaining body from the parser
Cleans out any remaining body from the parser
- Attributes
- protected
-
def
ensuring(cond: (Http1Stage[F]) ⇒ Boolean, msg: ⇒ Any): Http1Stage[F]
- Implicit
- This member is added by an implicit conversion from Http1Stage[F] to Ensuring[Http1Stage[F]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: (Http1Stage[F]) ⇒ Boolean): Http1Stage[F]
- Implicit
- This member is added by an implicit conversion from Http1Stage[F] to Ensuring[Http1Stage[F]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean, msg: ⇒ Any): Http1Stage[F]
- Implicit
- This member is added by an implicit conversion from Http1Stage[F] to Ensuring[Http1Stage[F]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean): Http1Stage[F]
- Implicit
- This member is added by an implicit conversion from Http1Stage[F] to Ensuring[Http1Stage[F]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
fatalError(t: Throwable, msg: String): Unit
Called when a fatal error has occurred The method logs an error and shuts down the stage, sending the error outbound
Called when a fatal error has occurred The method logs an error and shuts down the stage, sending the error outbound
- Attributes
- protected
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
def
formatted(fmtstr: String): String
- Implicit
- This member is added by an implicit conversion from Http1Stage[F] to StringFormat[Http1Stage[F]] performed by method StringFormat in scala.Predef.
- Definition Classes
- StringFormat
- Annotations
- @inline()
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
getEncoder(connectionHeader: Option[Connection], bodyEncoding: Option[Transfer-Encoding], lengthHeader: Option[Content-Length], trailer: F[Headers], rr: StringWriter, minor: Int, closeOnFinish: Boolean): Http1Writer[F]
Get the proper body encoder based on the message headers, adding the appropriate Connection and Transfer-Encoding headers along the way
Get the proper body encoder based on the message headers, adding the appropriate Connection and Transfer-Encoding headers along the way
- Attributes
- protected
-
final
def
getEncoder(msg: Message[F], rr: StringWriter, minor: Int, closeOnFinish: Boolean): Http1Writer[F]
Get the proper body encoder based on the message headers
Get the proper body encoder based on the message headers
- Attributes
- protected
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
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()
-
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
- @native() @throws( ... )
-
def
→[B](y: B): (Http1Stage[F], B)
- Implicit
- This member is added by an implicit conversion from Http1Stage[F] to ArrowAssoc[Http1Stage[F]] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc