java.lang.Object
- akka.stream.impl.FanIn.SubInput<T>

All Implemented Interfaces:

java.io.Serializable, org.reactivestreams.Subscriber<T>, scala.Equals, scala.Product, scala.Serializable

Enclosing class:

FanIn
```
public static final class FanIn.SubInput<T>
extends java.lang.Object
implements org.reactivestreams.Subscriber<T>, scala.Product, scala.Serializable
```
See Also:

Serialized Form

Constructor Summary

Constructors
Constructor Description

SubInput(ActorRef impl, int id)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`boolean`	`canEqual(java.lang.Object x$1)`
`<T> FanIn.SubInput<T>`	`copy(ActorRef impl, int id)`
`<T> ActorRef`	`copy$default$1()`
`<T> int`	`copy$default$2()`
`boolean`	`equals(java.lang.Object x$1)`
`int`	`hashCode()`
`int`	`id()`
`ActorRef`	`impl()`
`void`	`onComplete()`
`void`	`onError(java.lang.Throwable cause)`
`void`	`onNext(T element)`
`void`	`onSubscribe(org.reactivestreams.Subscription subscription)`
`int`	`productArity()`
`java.lang.Object`	`productElement(int x$1)`
`scala.collection.Iterator<java.lang.Object>`	`productIterator()`
`java.lang.String`	`productPrefix()`
`java.lang.String`	`toString()`

Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait

- Constructor Detail
  - SubInput
```
public SubInput(ActorRef impl,
                int id)
```
- Method Detail
  - impl
```
public ActorRef impl()
```
  - id
```
public int id()
```
  - onError
```
public void onError(java.lang.Throwable cause)
```
    Specified by:
    
    onError in interface org.reactivestreams.Subscriber<T>
  - onComplete
```
public void onComplete()
```
    Specified by:
    
    onComplete in interface org.reactivestreams.Subscriber<T>
  - onNext
```
public void onNext(T element)
```
    Specified by:
    
    onNext in interface org.reactivestreams.Subscriber<T>
  - onSubscribe
```
public void onSubscribe(org.reactivestreams.Subscription subscription)
```
    Specified by:
    
    onSubscribe in interface org.reactivestreams.Subscriber<T>
  - copy
```
public <T> FanIn.SubInput<T> copy(ActorRef impl,
                                  int id)
```
  - copy$default$1
```
public <T> ActorRef copy$default$1()
```
  - copy$default$2
```
public <T> int copy$default$2()
```
  - productPrefix
```
public java.lang.String productPrefix()
```
    Specified by:
    
    productPrefix in interface scala.Product
  - productArity
```
public int productArity()
```
    Specified by:
    
    productArity in interface scala.Product
  - productElement
```
public java.lang.Object productElement(int x$1)
```
    Specified by:
    
    productElement in interface scala.Product
  - productIterator
```
public scala.collection.Iterator<java.lang.Object> productIterator()
```
    Specified by:
    
    productIterator in interface scala.Product
  - canEqual
```
public boolean canEqual(java.lang.Object x$1)
```
    Specified by:
    
    canEqual in interface scala.Equals
  - hashCode
```
public int hashCode()
```
    Overrides:
    
    hashCode in class java.lang.Object
  - toString
```
public java.lang.String toString()
```
    Overrides:
    
    toString in class java.lang.Object
  - equals
```
public boolean equals(java.lang.Object x$1)
```
    Specified by:
    
    equals in interface scala.Equals
    
    Overrides:
    
    equals in class java.lang.Object

Class FanIn.SubInput<T>

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

SubInput

Method Detail

impl

id

onError

onComplete

onNext

onSubscribe

copy

copy$default$1

copy$default$2

productPrefix

productArity

productElement

productIterator

canEqual

hashCode

toString

equals