slick.memory.MemoryProfile

StreamingQueryAction

class StreamingQueryAction[R, T] extends MemoryDriver.StreamingDriverAction[R, T, Read] with SynchronousDatabaseAction[R, Streaming[T], HeapBackend, Read]

Source
MemoryProfile.scala
Linear Supertypes
Type Hierarchy Learn more about scaladoc diagrams
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. StreamingQueryAction
  2. SynchronousDatabaseAction
  3. FixedBasicStreamingAction
  4. FixedBasicAction
  5. BasicStreamingAction
  6. BasicAction
  7. DatabaseAction
  8. DBIOAction
  9. Dumpable
  10. AnyRef
  11. Any
Implicitly
  1. by any2stringadd
  2. by any2stringfmt
  3. by any2ArrowAssoc
  4. by any2Ensuring
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new StreamingQueryAction(tree: Node, param: Any)

Type Members

  1. type ResultAction[+R, +S <: NoStream, -E <: Effect] = BasicAction[R, S, E]

    Definition Classes
    FixedBasicActionBasicAction
  2. type StreamState = Iterator[T]

    The type used by this action for the state of a suspended stream.

    The type used by this action for the state of a suspended stream. A call to emitStream produces such a state which is then fed back into the next call.

    Definition Classes
    StreamingQueryActionSynchronousDatabaseAction

Value Members

  1. final def !=(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any
  3. final def ##(): Int

    Definition Classes
    AnyRef → Any
  4. def +(other: String): String

    Implicit information
    This member is added by an implicit conversion from MemoryDriver.StreamingQueryAction[R, T] to StringAdd performed by method any2stringadd in scala.Predef.
    Definition Classes
    StringAdd
  5. def ->[B](y: B): (MemoryDriver.StreamingQueryAction[R, T], B)

    Implicit information
    This member is added by an implicit conversion from MemoryDriver.StreamingQueryAction[R, T] to ArrowAssoc[MemoryDriver.StreamingQueryAction[R, T]] performed by method any2ArrowAssoc in scala.Predef.
    Definition Classes
    ArrowAssoc
    Annotations
    @inline()
  6. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  7. final def ==(arg0: Any): Boolean

    Definition Classes
    Any
  8. final def >>[R2, S2 <: NoStream, E2 <: Effect](a: DBIOAction[R2, S2, E2]): DBIOAction[R2, S2, Read with E2]

    A shortcut for andThen.

    A shortcut for andThen.

    Definition Classes
    DBIOAction
  9. def andFinally[E2 <: Effect](a: DBIOAction[_, NoStream, E2]): DBIOAction[R, Streaming[T], Read with E2]

    Run another action after this action, whether it succeeds or fails, and then return the result of the first action.

    Run another action after this action, whether it succeeds or fails, and then return the result of the first action. If the first action fails, its failure is propagated, whether the second action fails or succeeds. If the first action succeeds, a failure of the second action is propagated.

    Definition Classes
    SynchronousDatabaseActionDBIOAction
  10. def andThen[R2, S2 <: NoStream, E2 <: Effect](a: DBIOAction[R2, S2, E2]): DBIOAction[R2, S2, Read with E2]

    Run another action after this action, if it completed successfully, and return the result of the second action.

    Run another action after this action, if it completed successfully, and return the result of the second action. If either of the two actions fails, the resulting action also fails.

    Definition Classes
    SynchronousDatabaseActionDBIOAction
  11. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  12. def asTry: DBIOAction[Try[R], NoStream, Read]

    Convert a successful result v of this action into a successful result Success(v) and a failure t into a successful result Failure(t).

    Convert a successful result v of this action into a successful result Success(v) and a failure t into a successful result Failure(t). This is the most generic combinator that can be used for error recovery. If possible, use andFinally or cleanUp instead, because those combinators, unlike asTry, support streaming.

    Definition Classes
    SynchronousDatabaseActionDBIOAction
  13. def cancelStream(context: StreamingContext, state: StreamState): Unit

    Dispose of a StreamState when a streaming action is cancelled.

    Dispose of a StreamState when a streaming action is cancelled. Whenever emitStream returns null or throws an Exception, it needs to dispose of the state itself. This method will not be called in these cases.

    Definition Classes
    SynchronousDatabaseAction
  14. def cleanUp[E2 <: Effect](f: (Option[Throwable]) ⇒ DBIOAction[_, NoStream, E2], keepFailure: Boolean = true)(implicit executor: ExecutionContext): DBIOAction[R, Streaming[T], Read with E2]

    Run another action after this action, whether it succeeds or fails, in order to clean up or transform an error produced by this action.

    Run another action after this action, whether it succeeds or fails, in order to clean up or transform an error produced by this action. The clean-up action is computed from the failure of this action, wrapped in Some, or None if this action succeeded.

    keepFailure

    If this action returns successfully, the resulting action also returns successfully unless the clean-up action fails. If this action fails and keepFailure is set to true (the default), the resulting action fails with the same error, no matter whether the clean-up action succeeds or fails. If keepFailure is set to false, an error from the clean-up action will override the error from this action.

    Definition Classes
    DBIOAction
  15. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  16. def emitStream(ctx: HeapBackend.BasicStreamingActionContext, limit: Long, state: StreamState): StreamState

    Run this action synchronously and emit results to the context.

    Run this action synchronously and emit results to the context. This methods may throw an Exception to indicate a failure.

    limit

    The maximum number of results to emit, or Long.MaxValue for no limit.

    state

    The state returned by a previous invocation of this method, or null if a new stream should be produced.

    returns

    A stream state if there are potentially more results available, or null if the stream is finished.

    Definition Classes
    StreamingQueryActionSynchronousDatabaseAction
  17. def ensuring(cond: (MemoryDriver.StreamingQueryAction[R, T]) ⇒ Boolean, msg: ⇒ Any): MemoryDriver.StreamingQueryAction[R, T]

    Implicit information
    This member is added by an implicit conversion from MemoryDriver.StreamingQueryAction[R, T] to Ensuring[MemoryDriver.StreamingQueryAction[R, T]] performed by method any2Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  18. def ensuring(cond: (MemoryDriver.StreamingQueryAction[R, T]) ⇒ Boolean): MemoryDriver.StreamingQueryAction[R, T]

    Implicit information
    This member is added by an implicit conversion from MemoryDriver.StreamingQueryAction[R, T] to Ensuring[MemoryDriver.StreamingQueryAction[R, T]] performed by method any2Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  19. def ensuring(cond: Boolean, msg: ⇒ Any): MemoryDriver.StreamingQueryAction[R, T]

    Implicit information
    This member is added by an implicit conversion from MemoryDriver.StreamingQueryAction[R, T] to Ensuring[MemoryDriver.StreamingQueryAction[R, T]] performed by method any2Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  20. def ensuring(cond: Boolean): MemoryDriver.StreamingQueryAction[R, T]

    Implicit information
    This member is added by an implicit conversion from MemoryDriver.StreamingQueryAction[R, T] to Ensuring[MemoryDriver.StreamingQueryAction[R, T]] performed by method any2Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  21. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  22. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  23. def failed: DBIOAction[Throwable, NoStream, Read]

    Return an action which contains the Throwable with which this action failed as its result.

    Return an action which contains the Throwable with which this action failed as its result. If this action succeeded, the resulting action fails with a NoSuchElementException.

    Definition Classes
    SynchronousDatabaseActionDBIOAction
  24. final def filter(p: (R) ⇒ Boolean)(implicit executor: ExecutionContext): DBIOAction[R, NoStream, Read]

    Filter the result of this action with the given predicate.

    Filter the result of this action with the given predicate. If the predicate matches, the original result is returned, otherwise the resulting action fails with a NoSuchElementException.

    Definition Classes
    DBIOAction
  25. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  26. def flatMap[R2, S2 <: NoStream, E2 <: Effect](f: (R) ⇒ DBIOAction[R2, S2, E2])(implicit executor: ExecutionContext): DBIOAction[R2, S2, Read with E2]

    Use the result produced by the successful execution of this action to compute and then run the next action in sequence.

    Use the result produced by the successful execution of this action to compute and then run the next action in sequence. The resulting action fails if either this action, the computation, or the computed action fails.

    Definition Classes
    DBIOAction
  27. def formatted(fmtstr: String): String

    Implicit information
    This member is added by an implicit conversion from MemoryDriver.StreamingQueryAction[R, T] to StringFormat performed by method any2stringfmt in scala.Predef.
    Definition Classes
    StringFormat
    Annotations
    @inline()
  28. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  29. def getDumpInfo: DumpInfo

    Return the name, main info, attribute info and named children

    Return the name, main info, attribute info and named children

    Definition Classes
    StreamingQueryActionDumpable
  30. def getIterator(ctx: HeapBackend.BasicActionContext): Iterator[T]

    Attributes
    protected[this]
  31. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  32. def head: MemoryDriver.DriverAction[T, NoStream, Read]

    Create an Action that returns only the first value of this stream of data.

    Create an Action that returns only the first value of this stream of data. The Action will fail if the stream is empty. Only available on streaming Actions.

    Definition Classes
    StreamingQueryActionBasicStreamingAction
  33. def headOption: MemoryDriver.DriverAction[Option[T], NoStream, Read]

    Create an Action that returns only the first value of this stream of data as an Option.

    Create an Action that returns only the first value of this stream of data as an Option. Only available on streaming Actions.

    Definition Classes
    StreamingQueryActionBasicStreamingAction
  34. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  35. def isLogged: Boolean

    Whether or not this action should be included in log output by default.

    Whether or not this action should be included in log output by default.

    Definition Classes
    DatabaseActionDBIOAction
  36. def map[R2](f: (R) ⇒ R2)(implicit executor: ExecutionContext): DBIOAction[R2, NoStream, Read]

    Transform the result of a successful execution of this action.

    Transform the result of a successful execution of this action. If this action fails, the resulting action also fails.

    Definition Classes
    DBIOAction
  37. def named(name: String): DBIOAction[R, Streaming[T], Read]

    Get a wrapping action which has a name that will be included in log output.

    Get a wrapping action which has a name that will be included in log output.

    Definition Classes
    DBIOAction
  38. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  39. def nonFusedEquivalentAction: DBIOAction[R, Streaming[T], Read]

    Get the equivalent non-fused action if this action has been fused, otherwise this action is returned.

    Get the equivalent non-fused action if this action has been fused, otherwise this action is returned.

    Definition Classes
    DBIOAction
  40. final def notify(): Unit

    Definition Classes
    AnyRef
  41. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  42. def run(ctx: HeapBackend.BasicActionContext): R

    Run this action synchronously and produce a result, or throw an Exception to indicate a failure.

    Run this action synchronously and produce a result, or throw an Exception to indicate a failure.

    Definition Classes
    StreamingQueryActionSynchronousDatabaseAction
  43. def supportsStreaming: Boolean

    Whether or not this action supports streaming results.

    Whether or not this action supports streaming results. An action with a Streaming result type must either support streaming directly or have a nonFusedEquivalentAction which supports streaming. This flag is not used if the Action has a NoStream result type.

    Definition Classes
    SynchronousDatabaseAction
  44. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  45. def toString(): String

    Definition Classes
    AnyRef → Any
  46. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  47. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  48. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  49. def withFilter(p: (R) ⇒ Boolean)(implicit executor: ExecutionContext): DBIOAction[R, NoStream, Read]

    Definition Classes
    DBIOAction
  50. def withPinnedSession: DBIOAction[R, Streaming[T], Read]

    Use a pinned database session when running this action.

    Use a pinned database session when running this action. If it is composed of multiple database actions, they will all use the same session, even when sequenced with non-database actions. For non-composite or non-database actions, this has no effect.

    Definition Classes
    SynchronousDatabaseActionDBIOAction
  51. def zip[R2, E2 <: Effect](a: DBIOAction[R2, NoStream, E2]): DBIOAction[(R, R2), NoStream, Read with E2]

    Run another action after this action, if it completed successfully, and return the result of both actions.

    Run another action after this action, if it completed successfully, and return the result of both actions. If either of the two actions fails, the resulting action also fails.

    Definition Classes
    SynchronousDatabaseActionDBIOAction
  52. def [B](y: B): (MemoryDriver.StreamingQueryAction[R, T], B)

    Implicit information
    This member is added by an implicit conversion from MemoryDriver.StreamingQueryAction[R, T] to ArrowAssoc[MemoryDriver.StreamingQueryAction[R, T]] performed by method any2ArrowAssoc in scala.Predef.
    Definition Classes
    ArrowAssoc

Shadowed Implicit Value Members

  1. val self: Any

    Implicit information
    This member is added by an implicit conversion from MemoryDriver.StreamingQueryAction[R, T] to StringAdd performed by method any2stringadd in scala.Predef.
    Shadowing
    This implicitly inherited member is ambiguous. One or more implicitly inherited members have similar signatures, so calling this member may produce an ambiguous implicit conversion compiler error.
    To access this member you can use a type ascription:
    (streamingQueryAction: StringAdd).self
    Definition Classes
    StringAdd
  2. val self: Any

    Implicit information
    This member is added by an implicit conversion from MemoryDriver.StreamingQueryAction[R, T] to StringFormat performed by method any2stringfmt in scala.Predef.
    Shadowing
    This implicitly inherited member is ambiguous. One or more implicitly inherited members have similar signatures, so calling this member may produce an ambiguous implicit conversion compiler error.
    To access this member you can use a type ascription:
    (streamingQueryAction: StringFormat).self
    Definition Classes
    StringFormat

Deprecated Value Members

  1. def x: MemoryDriver.StreamingQueryAction[R, T]

    Implicit information
    This member is added by an implicit conversion from MemoryDriver.StreamingQueryAction[R, T] to ArrowAssoc[MemoryDriver.StreamingQueryAction[R, T]] performed by method any2ArrowAssoc in scala.Predef.
    Shadowing
    This implicitly inherited member is ambiguous. One or more implicitly inherited members have similar signatures, so calling this member may produce an ambiguous implicit conversion compiler error.
    To access this member you can use a type ascription:
    (streamingQueryAction: ArrowAssoc[MemoryDriver.StreamingQueryAction[R, T]]).x
    Definition Classes
    ArrowAssoc
    Annotations
    @deprecated
    Deprecated

    (Since version 2.10.0) Use leftOfArrow instead

  2. def x: MemoryDriver.StreamingQueryAction[R, T]

    Implicit information
    This member is added by an implicit conversion from MemoryDriver.StreamingQueryAction[R, T] to Ensuring[MemoryDriver.StreamingQueryAction[R, T]] performed by method any2Ensuring in scala.Predef.
    Shadowing
    This implicitly inherited member is ambiguous. One or more implicitly inherited members have similar signatures, so calling this member may produce an ambiguous implicit conversion compiler error.
    To access this member you can use a type ascription:
    (streamingQueryAction: Ensuring[MemoryDriver.StreamingQueryAction[R, T]]).x
    Definition Classes
    Ensuring
    Annotations
    @deprecated
    Deprecated

    (Since version 2.10.0) Use resultOfEnsuring instead

Inherited from FixedBasicStreamingAction[R, T, Read]

Inherited from FixedBasicAction[R, Streaming[T], Read]

Inherited from BasicStreamingAction[R, T, Read]

Inherited from BasicAction[R, Streaming[T], Read]

Inherited from DatabaseAction[R, Streaming[T], Read]

Inherited from DBIOAction[R, Streaming[T], Read]

Inherited from Dumpable

Inherited from AnyRef

Inherited from Any

Inherited by implicit conversion any2stringadd from MemoryDriver.StreamingQueryAction[R, T] to StringAdd

Inherited by implicit conversion any2stringfmt from MemoryDriver.StreamingQueryAction[R, T] to StringFormat

Inherited by implicit conversion any2ArrowAssoc from MemoryDriver.StreamingQueryAction[R, T] to ArrowAssoc[MemoryDriver.StreamingQueryAction[R, T]]

Inherited by implicit conversion any2Ensuring from MemoryDriver.StreamingQueryAction[R, T] to Ensuring[MemoryDriver.StreamingQueryAction[R, T]]

Ungrouped