Package org.apache.pekko.stream.scaladsl

Class MergeHub$

java.lang.Object

org.apache.pekko.stream.scaladsl.MergeHub$

public class MergeHub$
extends Object

A MergeHub is a special streaming hub that is able to collect streamed elements from a dynamic set of producers. It consists of two parts, a Source and a Sink. The Source streams the element to a consumer from its merged inputs. Once the consumer has been materialized, the Source returns a materialized value which is the corresponding Sink. This Sink can then be materialized arbitrary many times, where each of the new materializations will feed its consumed elements to the original Source.

Field Summary

Fields

Modifier and Type	Field	Description
static final MergeHub$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
MergeHub$()

Method Summary

Modifier and Type	Method	Description
<T> boolean	$lessinit$greater$default$2()	INTERNAL API
<T> Source<T,Sink<T,NotUsed>>	source()
<T> Source<T,Sink<T,NotUsed>>	source(int perProducerBufferSize)
<T> Source<T,scala.Tuple2<Sink<T,NotUsed>,org.apache.pekko.stream.scaladsl.MergeHub.DrainingControl>>	sourceWithDraining()
<T> Source<T,scala.Tuple2<Sink<T,NotUsed>,org.apache.pekko.stream.scaladsl.MergeHub.DrainingControl>>	sourceWithDraining(int perProducerBufferSize)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

MODULE$

public static final MergeHub$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

MergeHub$

public MergeHub$()

Method Details

$lessinit$greater$default$2

public <T> boolean $lessinit$greater$default$2()

INTERNAL API

source

public <T> Source<T,Sink<T,NotUsed>> source(int perProducerBufferSize)

sourceWithDraining

public <T>
Source<T,scala.Tuple2<Sink<T,NotUsed>,org.apache.pekko.stream.scaladsl.MergeHub.DrainingControl>> sourceWithDraining(int perProducerBufferSize)

source

public <T> Source<T,Sink<T,NotUsed>> source()

sourceWithDraining

public <T>
Source<T,scala.Tuple2<Sink<T,NotUsed>,org.apache.pekko.stream.scaladsl.MergeHub.DrainingControl>> sourceWithDraining()