DatabasePublisher

slick.basic.DatabasePublisher
abstract class DatabasePublisher[T] extends Publisher[T]

A Reactive Streams Publisher for database Actions.

Attributes

Source:
DatabasePublisher.scala
Graph
Supertypes
trait Publisher[T]
class Object
trait Matchable
class Any
Self type

Members list

Concise view

Value members

Concrete methods

def foreach[U](f: T => U)(implicit ec: ExecutionContext): Future[Unit]

Consume the stream, processing each element sequentially on the specified ExecutionContext. The resulting Future completes when all elements have been processed or an error was signaled.

Consume the stream, processing each element sequentially on the specified ExecutionContext. The resulting Future completes when all elements have been processed or an error was signaled.

Attributes

Source:
DatabasePublisher.scala
def mapResult[U](f: T => U): DatabasePublisher[U]

Create a Publisher that runs a synchronous mapping function on this Publisher. This can be used to materialize LOB values in a convenient way.

Create a Publisher that runs a synchronous mapping function on this Publisher. This can be used to materialize LOB values in a convenient way.

Attributes

Source:
DatabasePublisher.scala

Inherited methods

def subscribe(x$0: Subscriber[_ >: T <: <FromJavaObject>]): Unit

Attributes

Inherited from:
Publisher