Packages

object Reference

Source
Reference.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Reference
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. def flow(): Flow[ReferenceWriteMessage, ReferenceWriteResult, NotUsed]

    API doc should describe what will be done to the incoming messages to the flow, and what messages will be emitted by the flow.

  2. def flowAsyncMapped()(implicit ec: ExecutionContext): Flow[ReferenceWriteMessage, ReferenceWriteResult, NotUsed]

    If the operator needs an ExecutionContext, take it as an implicit parameter.

  3. def flowWithResource(): Flow[ReferenceWriteMessage, ReferenceWriteResult, NotUsed]

    An implementation of a flow that needs access to materializer or attributes during materialization.

  4. def source(settings: SourceSettings): Source[ReferenceReadResult, Future[Done]]

    API doc should describe where the messages are coming from.

    API doc should describe where the messages are coming from.

    Also describe the significance of the materialized value.