Class AbruptTerminationException

This exception signals that an actor implementing a Reactive Streams Subscriber, Publisher or Processor has been terminated without being notified by an onError, onComplete or cancel signal. This usually happens when an ActorSystem is shut down while stream processing actors are still running.

Inheritance

Object

Exception

AbruptTerminationException

Implements

ISerializable

Inherited Members

Exception.GetBaseException()

Exception.GetObjectData(SerializationInfo, StreamingContext)

Exception.GetType()

Exception.ToString()

Exception.Data

Exception.HelpLink

Exception.HResult

Exception.InnerException

Exception.Message

Exception.Source

Exception.StackTrace

Exception.TargetSite

Exception.SerializeObjectState

Object.Equals(Object)

Object.Equals(Object, Object)

Object.GetHashCode()

Object.MemberwiseClone()

Object.ReferenceEquals(Object, Object)

Namespace: Akka.Streams

Assembly: Akka.Streams.dll

Syntax

[Serializable]
public class AbruptTerminationException : Exception, ISerializable

Constructors

AbruptTerminationException(IActorRef)

Initializes a new instance of the AbruptTerminationException class.

Declaration

public AbruptTerminationException(IActorRef actor)

Parameters

Type	Name	Description
IActorRef	actor	The actor that was terminated.

AbruptTerminationException(SerializationInfo, StreamingContext)

Initializes a new instance of the AbruptTerminationException class.

Declaration

protected AbruptTerminationException(SerializationInfo info, StreamingContext context)

Parameters

Type	Name	Description
SerializationInfo	info	The SerializationInfo that holds the serialized object data about the exception being thrown.
StreamingContext	context	The StreamingContext that contains contextual information about the source or destination.

Fields

Actor

The actor that was terminated without notification.

Declaration

public readonly IActorRef Actor

Field Value

Type	Description
IActorRef

Implements

ISerializable

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(Object)