Packages

final class Resource extends AnyRef

Some connectors might require an external resource that is used in the Source, Flow and/or Sink factories.

For example dynamodb connector needs a DynamoClient to create Sources and Flows. Another example is Google Pub Sub gRPC connector that uses Grpc Publishers and Subscribers to create Sources and Sinks. Another connector, Pekko Connectors Kafka, uses an actor that can be shared across different streams.

If your connector uses such a resource and it is possible to reuse that resource across different Pekko Stream operator factories, put that resource to a separate class like below.

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

Value Members

  1. def cleanup(): Unit

    Resource cleanup logic

  2. val connection: Flow[ByteString, ByteString, NotUsed]
  3. val settings: ResourceSettings