ActorProcessor

java.lang.Object
- akka.stream.impl.ActorPublisher<O>
- - akka.stream.impl.ActorProcessor<I,O>

All Implemented Interfaces:

org.reactivestreams.Processor<I,O>, org.reactivestreams.Publisher<O>, org.reactivestreams.Subscriber<I>
```
public class ActorProcessor<I,O>
extends ActorPublisher<O>
implements org.reactivestreams.Processor<I,O>
```
INTERNAL API

Nested Class Summary
- Nested classes/interfaces inherited from class akka.stream.impl.ActorPublisher
  ActorPublisher.NormalShutdownException

Constructor Summary

Constructors
Constructor Description

ActorProcessor(ActorRef impl)

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`static <I,O> ActorProcessor<I,O>`	`apply(ActorRef impl)`
`void`	`onComplete()`
`void`	`onError(java.lang.Throwable t)`
`void`	`onNext(I elem)`
`void`	`onSubscribe(org.reactivestreams.Subscription s)`

Methods inherited from class akka.stream.impl.ActorPublisher
apply, impl, NormalShutdownReason, NormalShutdownReasonMessage, shutdown, SomeNormalShutdownReason, subscribe, takePendingSubscribers, wakeUpMsg

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

Methods inherited from interface org.reactivestreams.Publisher
subscribe

- Constructor Detail
  - ActorProcessor
```
public ActorProcessor(ActorRef impl)
```
- Method Detail
  - apply
```
public static <I,O> ActorProcessor<I,O> apply(ActorRef impl)
```
  - onSubscribe
```
public void onSubscribe(org.reactivestreams.Subscription s)
```
    Specified by:
    
    onSubscribe in interface org.reactivestreams.Subscriber<I>
  - onError
```
public void onError(java.lang.Throwable t)
```
    Specified by:
    
    onError in interface org.reactivestreams.Subscriber<I>
  - onComplete
```
public void onComplete()
```
    Specified by:
    
    onComplete in interface org.reactivestreams.Subscriber<I>
  - onNext
```
public void onNext(I elem)
```
    Specified by:
    
    onNext in interface org.reactivestreams.Subscriber<I>