object Consumer
- Alphabetic
- By Inheritance
- Consumer
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- trait Control extends AnyRef
The materialized value of the consumer sources.
The materialized value of the consumer sources. Used for control shutdown.
Not for user extension.
- Annotations
- @DoNotInherit()
- trait DrainingControl[T] extends Control
Combines control and stream completion materialized values, allowing the stream to be stopped in a controlled way without losing checkpoints
Combines control and stream completion materialized values, allowing the stream to be stopped in a controlled way without losing checkpoints
The stream completion materialized value will typically be that of a sink (e.g. 'Sink.ignore')
Not for user extension.
- Annotations
- @DoNotInherit()
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- def createDrainingControl[T](pair: Pair[Control, CompletionStage[T]]): DrainingControl[T]
Combine the consumer control and the stream completion signal materialized values into one, so that the stream can be stopped without losing checkpoints.
Combine the consumer control and the stream completion signal materialized values into one, so that the stream can be stopped without losing checkpoints.
For use with the 'mapMaterializedValue' combination of materialized values.
- def createDrainingControl[T](c: Control, mat: CompletionStage[T]): DrainingControl[T]
Combine the consumer control and the stream completion signal materialized values into one, so that the stream can be stopped without losing checkpoints.
Combine the consumer control and the stream completion signal materialized values into one, so that the stream can be stopped without losing checkpoints.
For use with the 'toMat' combination of materialized values.
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def pairSource(settings: ConsumerSettings, sdkClientBuilder: EventProcessorClientBuilder, checkpointSettings: CheckpointSettings, checkpointStore: CheckpointStore): Source[Pair[EventData, Checkpointable], Control]
- def source[T](settings: ConsumerSettings, sdkClientBuilder: EventProcessorClientBuilder, checkpointSettings: CheckpointSettings, checkpointStore: CheckpointStore, f: Function2[EventData, Checkpointable, T]): Source[T, Control]
Source which applies a function to the
EventDataand checkpointable to build an arbitrary type.Source which applies a function to the
EventDataand checkpointable to build an arbitrary type. It is equivalent to 'sourceWithCheckpointableContext.asSource().map(pair -> f(pair.first(), pair.second()))' but without the overhead of the intermediate SourceWithContext. Supports "at-least-once delivery". - def sourceWithCheckpointableContext(settings: ConsumerSettings, sdkClientBuilder: EventProcessorClientBuilder, checkpointSettings: CheckpointSettings, checkpointStore: CheckpointStore): SourceWithContext[EventData, Checkpointable, Control]
Source which emits 'EventData' together with the checkpointable as flow context, which allows checkpointing to the checkpoint store.
Source which emits 'EventData' together with the checkpointable as flow context, which allows checkpointing to the checkpoint store. Supports "at-least-once delivery": each event will likely be delivered once, but could be redelivered in failure cases.
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()