object QResponse extends Serializable
- Alphabetic
- By Inheritance
- QResponse
- Serializable
- Serializable
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Type Members
- final class HttpResponseStreamFailureException extends Exception
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
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
- def body[S[_]]: PLens[QResponse[S], QResponse[S], Process[[β$1$]Free[S, β$1$], ByteVector], Process[[β$1$]Free[S, β$1$], ByteVector]]
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
- def empty[S[_]]: QResponse[S]
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def header[S[_]](key: Extractable): Optional[QResponse[S], org.http4s.HeaderKey.Extractable.HeaderT]
- def headers[S[_]]: PLens[QResponse[S], QResponse[S], Headers, Headers]
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def json[A, S[_]](status: Status, a: A)(implicit arg0: EncodeJson[A]): QResponse[S]
-
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 ok[S[_]]: QResponse[S]
- def response[S[_], A](status: Status, a: A)(implicit E: EntityEncoder[A], S0: :<:[Task, S]): QResponse[S]
- def status[S[_]]: PLens[QResponse[S], QResponse[S], Status, Status]
- def streaming[S[_], A, E](p: Process[[γ$13$]EitherT[[β$12$]Free[S, β$12$], E, γ$13$], A])(implicit A: EntityEncoder[A], S0: :<:[Task, S], S1: :<:[[β$14$]Failure[E, β$14$], S]): Free[S, QResponse[S]]
-
def
streaming[S[_], A](p: Process[[β$9$]Free[S, β$9$], A])(implicit E: EntityEncoder[A], S0: :<:[Task, S]): Free[S, QResponse[S]]
This QResponse constructor attempts to eliminate all effects in this stream that aren't actually part of the response stream by eagerly evaluating the "first few" effects of the stream.
This QResponse constructor attempts to eliminate all effects in this stream that aren't actually part of the response stream by eagerly evaluating the "first few" effects of the stream. Examples of such effects are opening a quasar filesystem file, initiating a query to a connector, etc. Doing so allows us to provide a proper error response to clients instead of sending a Http OK and then failing to stream the response body because actually it turned out the file didn't exist after all.
The better fix for this problem would probably be to avoid constructing such processes (at least for use in the web layer) and instead make a distinction between the effects that create a stream and the effects that "run" the stream.
In the meantime, this constructor should mostly do the right thing if provided with such processes.
- Annotations
- @SuppressWarnings()
- def string[S[_]](status: Status, s: slamdata.Predef.String): QResponse[S]
-
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( ... )