```
public class MergeHub$
extends java.lang.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.

All Methods Instance Methods Concrete Methods
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>,akka.stream.scaladsl.MergeHub.DrainingControl>>`	`sourceWithDraining()`
`<T> Source<T,scala.Tuple2<Sink<T,NotUsed>,akka.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

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

INTERNAL API

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

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

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

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

Class MergeHub$