ActorPublisher(T).OnNext Method

ActorPublisherTOnNext Method

Sends an element to the stream subscriber. You are allowed to send as many elements as have been requested by the stream subscriber. This amount can be inquired with TotalDemand. It is only allowed to use OnNext(T) when IsActive and TotalDemand > 0, otherwise OnNext(T) will throw IllegalStateException.

Namespace: Akka.Streams.Actors
Assembly: Akka.Streams (in Akka.Streams.dll) Version: 1.2.3.129 (1.2.3.129)

Syntax

Copy

public void OnNext(
	T element
)

member OnNext : 
        element : 'T -> unit

Parameters

element: Type: T
TBD

Exceptions

Exception	Condition
IllegalStateException	This exception is thrown for a number of reasons. These include: when in the Active or PreSubscriber state This exception is thrown when the ActorPublisherT has zero TotalDemand. when in the ErrorEmitted state This exception is thrown when this ActorPublisherT has already terminated due to an error. when in the Completed or CompleteThenStop state This exception is thrown when this ActorPublisherT has already completed.

Exception

Condition

IllegalStateException

This exception is thrown for a number of reasons. These include:

when in the Active or PreSubscriber state: This exception is thrown when the ActorPublisherT has zero TotalDemand.
when in the ErrorEmitted state: This exception is thrown when this ActorPublisherT has already terminated due to an error.
when in the Completed or CompleteThenStop state: This exception is thrown when this ActorPublisherT has already completed.

Reference

ActorPublisherT Class

Akka.Streams.Actors Namespace