c

slick.jdbc.JdbcActionComponent

JdbcStreamingQueryActionExtensionMethodsImpl

class JdbcStreamingQueryActionExtensionMethodsImpl[R, T] extends JdbcProfile.JdbcQueryActionExtensionMethodsImpl[R, Streaming[T]] with JdbcProfile.BasicStreamingQueryActionExtensionMethodsImpl[R, T]

Source
JdbcActionComponent.scala
Linear Supertypes
JdbcProfile.BasicStreamingQueryActionExtensionMethodsImpl[R, T], JdbcProfile.JdbcQueryActionExtensionMethodsImpl[R, Streaming[T]], JdbcProfile.BasicQueryActionExtensionMethodsImpl[R, Streaming[T]], AnyRef, Any
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. JdbcStreamingQueryActionExtensionMethodsImpl
  2. BasicStreamingQueryActionExtensionMethodsImpl
  3. JdbcQueryActionExtensionMethodsImpl
  4. BasicQueryActionExtensionMethodsImpl
  5. AnyRef
  6. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

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

Value Members

  1. def mutate(sendEndMarker: Boolean = false): JdbcProfile.ProfileAction[Nothing, Streaming[ResultSetMutator[T]], Read with Write]

    Create an Action that can be streamed in order to modify a mutable result set.

    Create an Action that can be streamed in order to modify a mutable result set. All stream elements will be the same slick.jdbc.ResultSetMutator object but it is in a different state each time. Thre resulting stream is always non-buffered and events can be processed either synchronously or asynchronously (but all processing must happen in sequence).

    sendEndMarker

    If set to true, an extra event is sent after the end of the result set, poviding you with a chance to insert additional rows after seeing all results. Only end (to check for this special event) and insert may be called in the ResultSetMutator in this case.

  2. def mutate: JdbcProfile.ProfileAction[Nothing, Streaming[ResultSetMutator[T]], Read with Write]

    Same as mutate(sendEndMarker = false).

  3. def result: JdbcProfile.StreamingProfileAction[R, T, Read]

    An Action that runs this query.

    An Action that runs this query.

    Definition Classes
    JdbcStreamingQueryActionExtensionMethodsImpl → BasicStreamingQueryActionExtensionMethodsImpl → JdbcQueryActionExtensionMethodsImpl → BasicQueryActionExtensionMethodsImpl