class BodylessWriter extends ProcessWriter
Discards the body, killing it so as to clean up resources
- Source
- BodylessWriter.scala
- Alphabetic
- By Inheritance
- BodylessWriter
- ProcessWriter
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- All
Instance Constructors
-
new
BodylessWriter(headers: ByteBuffer, pipe: TailStage[ByteBuffer], close: Boolean)(implicit ec: ExecutionContext)
- headers
ByteBuffer representation of Headers to send
- pipe
the blaze
TailStage
, which takes ByteBuffers which will send the data downstream- ec
an ExecutionContext which will be used to complete operations
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 BodylessWriter to any2stringadd[BodylessWriter] performed by method any2stringadd in scala.Predef.
- Definition Classes
- any2stringadd
-
def
->[B](y: B): (BodylessWriter, B)
- Implicit
- This member is added by an implicit conversion from BodylessWriter to ArrowAssoc[BodylessWriter] 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
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
implicit
val
ec: ExecutionContext
- Attributes
- protected
- Definition Classes
- BodylessWriter → ProcessWriter
-
def
ensuring(cond: (BodylessWriter) ⇒ Boolean, msg: ⇒ Any): BodylessWriter
- Implicit
- This member is added by an implicit conversion from BodylessWriter to Ensuring[BodylessWriter] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: (BodylessWriter) ⇒ Boolean): BodylessWriter
- Implicit
- This member is added by an implicit conversion from BodylessWriter to Ensuring[BodylessWriter] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean, msg: ⇒ Any): BodylessWriter
- Implicit
- This member is added by an implicit conversion from BodylessWriter to Ensuring[BodylessWriter] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean): BodylessWriter
- Implicit
- This member is added by an implicit conversion from BodylessWriter to Ensuring[BodylessWriter] 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
exceptionFlush(): Future[Unit]
Called in the event of an Await failure to alert the pipeline to cleanup
Called in the event of an Await failure to alert the pipeline to cleanup
- Attributes
- protected
- Definition Classes
- ProcessWriter
-
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 BodylessWriter to StringFormat[BodylessWriter] performed by method StringFormat in scala.Predef.
- Definition Classes
- StringFormat
- Annotations
- @inline()
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- 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( ... )
-
def
writeBodyChunk(chunk: ByteVector, flush: Boolean): Future[Unit]
Write a ByteVector to the wire.
Write a ByteVector to the wire. If a request is cancelled, or the stream is closed this method should return a failed Future with Cancelled as the exception
- chunk
BodyChunk to write to wire
- returns
a future letting you know when its safe to continue
- Attributes
- protected
- Definition Classes
- BodylessWriter → ProcessWriter
-
def
writeEnd(chunk: ByteVector): Future[Boolean]
Write the ending chunk and, in chunked encoding, a trailer to the wire.
Write the ending chunk and, in chunked encoding, a trailer to the wire. If a request is cancelled, or the stream is closed this method should return a failed Future with Cancelled as the exception, or a Future with a Boolean to indicate whether the connection is to be closed or not.
- chunk
BodyChunk to write to wire
- returns
a future letting you know when its safe to continue (if
false
) or to close the connection (iftrue
)
- Attributes
- protected
- Definition Classes
- BodylessWriter → ProcessWriter
-
def
writeProcess(p: EntityBody): Task[Boolean]
Doesn't write the process, just the headers and kills the process, if an error if necessary
Doesn't write the process, just the headers and kills the process, if an error if necessary
- p
Process[Task, Chunk] that will be killed
- returns
the Task which when run will send the headers and kill the body process
- Definition Classes
- BodylessWriter → ProcessWriter
-
def
→[B](y: B): (BodylessWriter, B)
- Implicit
- This member is added by an implicit conversion from BodylessWriter to ArrowAssoc[BodylessWriter] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc